home *** CD-ROM | disk | FTP | other *** search
/ Aminet 4 / Aminet 4 - November 1994.iso / aminet / comm / misc / avmnfaxsrc1_33.lha / efax0.6a.c < prev    next >
C/C++ Source or Header  |  1994-06-03  |  66KB  |  2,163 lines
  1. #define Copyright         "Copyright 1994  Ed Casas"
  2.  
  3. #define Version          "efax v 0.6a"
  4.  
  5. /*
  6.     Copyright (C) 1994  Ed Casas
  7.  
  8.     This program is free software; you can redistribute it and/or modify
  9.     it under the terms of the GNU General Public License as published by
  10.     the Free Software Foundation; either version 2 of the License, or
  11.     (at your option) any later version.
  12.  
  13.     This program is distributed in the hope that it will be useful,
  14.     but WITHOUT ANY WARRANTY; without even the implied warranty of
  15.     MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  16.     GNU General Public License for more details.
  17.  
  18.     You should have received a copy of the GNU General Public License
  19.     along with this program; if not, write to the Free Software
  20.     Foundation, Inc., 675 Mass Ave, Cambridge, MA 02139, USA.
  21.  
  22.     You may contact the author by e-mail at: edc@ee.ubc.ca,
  23.     or by mail at: 2629 West 3rd Ave, Vancouver, BC, Canada,
  24.     V6K 1M4.
  25.  
  26. */
  27.  
  28. const char *Usage =
  29.   "Usage:\n"
  30.   "  %s [ option ]... [ -r pat | -t num file... ]\n"
  31. "Options:\n"
  32.   "  -c cap  set file format or receive capabilites to cap\n"
  33.   "  -d dev  use modem on device dev\n"
  34.   "  -g cmd  exec \"/bin/sh -c cmd\" for data calls\n"
  35.   "  -i str  send modem command ATstr at start\n"
  36.   "  -l id   set local indetification to id\n"
  37.   "  -o opt  use protocol option opt:\n"
  38.   "      1     use class 1 modem commands\n"
  39.   "      a     if first [data mode] answer attempt fails retry as fax\n"
  40.   "      e     ignore errors in modem initialization commands\n"
  41.   "      r     reverse bit order on receive\n"  
  42.   "      x     use XON instead of DC2 to trigger reception\n"
  43.   "      z     add 100 ms to pause before each modem comand (cumulative)\n"
  44.   "  -q ne   ask for retransmission if more than ne errors per page\n"
  45.   "  -s      share (unlock) modem device while waiting for call\n"
  46.   "  -v lvl  print messages of type in string lvl (ewinchamr)\n"
  47.   "  -w      don't answer phone, wait for OK or CONNECT instead\n"
  48.   "  -x fil  use uucp-style lock file fil\n"
  49.   "  -z str  send modem command ATstr when done\n"
  50.   "Commands:\n"
  51.   "  -r      answer and receive fax into files pat.001, pat.002, ... \n"
  52.   "  -t      send fax image files file... to telephone num\n"
  53.   ;
  54.  
  55. #include <ctype.h>        /* ANSI C */
  56. #include <errno.h>
  57. #include <signal.h>    
  58. #include <stdarg.h> 
  59. #include <stdio.h>
  60. #include <stdlib.h>
  61. #include <string.h>
  62. #include <time.h>
  63.  
  64. #include <fcntl.h>        /* POSIX */
  65. #include <unistd.h>
  66. #include <sys/types.h>
  67.  
  68. #include <sys/time.h>        /* select() */
  69.  
  70. #ifndef FD_SET
  71. #include <select.h>        /* for AIX */
  72. #endif
  73.  
  74. #include <sys/stat.h>        /* for SysV (?) */
  75.  
  76. #ifdef TERMIO
  77. #include <termio.h>
  78. #include <sys/ioctl.h>
  79. #define termios termio
  80. #define tcgetattr(fd, pt) ioctl(fd, TCGETA, pt)
  81. #define tcsetattr(fd, x, pt) ioctl(fd, TCSETAW, pt)
  82. #define cfsetospeed(pt, b) ((pt)->c_cflag = ((pt)->c_cflag & ~CBAUD) | b)
  83. #define cfsetispeed(pt, b)
  84. #define tcdrain(fd)
  85. #else
  86. #include <termios.h>
  87. #endif
  88.  
  89. #ifndef FILENAME_MAX
  90. #define FILENAME_MAX 255
  91. #endif
  92.  
  93. #ifndef u_char
  94. #define u_char unsigned char
  95. #endif
  96.  
  97. /* constants... */
  98.  
  99. #define FAXFILE "/dev/fax"  /* default fax modem device */
  100. #define LOGF     stderr     /* session log written to this stream */
  101.  
  102.                 /* delays/timeouts, in deciseconds */
  103. #define TO_RESET  26        /* timeout for modem reset commands (per Hayes) */
  104. #define T_CMD     1        /* pause before each modem command */
  105. #define TO_A      1200        /* dial/answer (Phase A) - modem may T.O. first */
  106.  
  107. #define TO_DATAF  150        /* software adaptive answer data connect */
  108.  
  109. #define T1 350            /* T.30 T1 - waiting for DIS/DCS before Phase B */
  110. #define T2 60            /* T.30 T2 - waiting for frame in Phase B */
  111. #define T3S 30            /* T.30 response timeout (not T3) */
  112. #define T4 30            /* T.30 T4 - between [re]transmissions of DIS */
  113.  
  114. #define TO_DRAIN 140        /* drain 4k modem buffer at 2400bps (tx) */
  115. #define TO_RTCMD 10        /* return to command mode after DLE-ETX (rx) */
  116. #define TO_FT    31        /* max delay after +F[TR][MH] command */
  117. #define TO_CHAR  51        /* per data character (max FILL length) */
  118. #define TO_ABRT  20        /* max delay after sending abort sequence */
  119.  
  120. #define TO_C2B    450        /* Class 2 DIS to CONNECT:(DCS+TCF+CFR)xretries */
  121. #define TO_C2X    20        /* Class 2 wait for XON: 2/5 of 5s timeout */
  122. #define TO_C2PP   200        /* Class 2 wait for ppr: (ppm+ppr)x3retries + 2 */
  123. #define TO_C2R    600        /* Class 2 receive: (TCF+FTT)x11 retrains + 5 */
  124. #define TO_C2EOR  60        /* Class 2 end of data rx (2 retrans x 3 s) */
  125.  
  126.  
  127. #define CMDBUFSIZE 128      /* longest possible modem command or response */
  128. #define DEFDISLEN 3        /* length of DIS initially transmitted */
  129. #define DEFCAP 1,3,0,2,0,0,0,0    /* default local capabilities */
  130. #define DLE_ETX "\020\003"  /* DLE-ETX (end of data) string */
  131. #define FNAMFT "%m%d%H%M%S" /* strftime() format for default file name */
  132. #define HDBLKFLAG '#'        /* prefix to force HDB (text) lock file style */
  133. #define IDLEN 20        /* length of T.30 identification strings */
  134. #define LOCKPOLLDELAY 15    /* seconds between checks of lock files */
  135. #define MAXDIS 8        /* maximum DIS frames sent without response (T1) */
  136. #define MAXFIFLEN 125        /* max FIF len = MAXFRLEN - (adx+ctl+FCF) - FCS */
  137. #define MAXFRLEN 130        /* max frame length = 3.45s x 300 bps / 8 */
  138. #define MAXGETTY 512        /* maximum length of ``getty'' (-g) command */
  139. #define MAXIOPT  100        /* maximum # of modem initialization commands */
  140. #define MAXLKFILE 16        /* maximum number of lock files */
  141. #define MAXMSGBUF 8192        /* maximum size of message buffer */
  142. #define MAXNULLS 2        /* maximum consecutive received nulls saved */
  143. #define MAXTSTAMP 80        /* maximum length of a time stamp */
  144. #define MAXTRAINERR 0        /* maximum errors allowed in training check data */
  145. #define MAXTRAIN 2        /* maximum training retries at lowest speed */
  146. #define MAXRETRY 3        /* maximum retries of unacknowledged commands */
  147. #define MINWRITE  128       /* minimum bytes per write() to modem */
  148. #define NCAP 8              /* number of fields in a capability string */
  149. #define NTXRETRY  3        /* maximum re-sends per page */
  150. #define RCVBUFSIZE 1024        /* read up to this many bytes at a time from fax */
  151. #define SNDBUFSIZE 1024        /* maximum bytes to write at a time to fax */
  152. #define T4RTCLEN  9        /* end of page mark for T.4 coded images */
  153. #define T4RTC    "\000\020\001\000\020\001\000\020\001"
  154.  
  155. enum  cchar {                /* control characters */
  156.   NUL, SOH, STX, ETX, EOT, ENQ, ACK, BEL, BS,  HT,  LF,
  157.   VT,  FF,  CR,  SO,  SI,  DLE, XON, DC2, XOFF,DC4, NAK,
  158.   SYN, ETB, CAN, EM,  SUB, ESC, FS,  GS,  RS,  US } ;
  159.  
  160. const char *prompts[] = {        /* modem responses that are prompts */
  161.   "OOK", "-CONNECT FAX", "CCONNECT", "NNO CARRIER", "EERROR",
  162.   "NNO DIALTONE", "BBUSY", "NNO ANSWER", "E+FCERROR", 0 } ;
  163.  
  164. enum promptcodes {            /* codes for modem prompts */
  165.    BUSY = 'B', CONNECT = 'C', OK = 'O', RING = 'R', NO = 'N',
  166.    ERROR = 'E' } ;
  167.  
  168. enum ttymodes                /* serial port modes */
  169.    { COMMAND, DROPDTR, SEND, ORIGINAL } ;
  170.  
  171.                 /* signals to be caught so can hang up phone */
  172. const int catch [] = { SIGHUP, SIGINT, SIGQUIT, SIGIOT, SIGSEGV, SIGALRM,
  173.                SIGTERM, SIGFPE, 0 } ;
  174.  
  175. typedef int cap [ NCAP ] ;        /* remote/local capabilities */
  176.  
  177.                                         /* capability fields... */
  178. enum  captype {                   VR, BR, WD, LN, DF, EC, BF, ST } ;
  179. const int capmax [ NCAP ] = {   1,  7,  3,  2,  3,  2,  1,  7 } ;
  180.                     /* & maximum values */
  181.  
  182.                     /* characters per second for br */
  183. const int cps [ 8 ] = { 300, 600, 900, 1200, 1500, 1800, 900, 1200 } ;
  184.  
  185.                     /* next br = fallback [ br ] */
  186. const int fallback [ 8 ] = { 0, 0, 1, 2, 7, 4, 3, 6 } ;
  187.  
  188.                     /* minimum scan time in ms  */
  189. const int delay [ 8 ] = { 0 , 5, 10, 10, 20, 20, 40, 40 } ;
  190.  
  191. /* Table to convert between T.30 DIS/DCS/DTC FIF and Class 2-like
  192.    capability codes. Uses br=6, 7 for V.17 at 7200, 9600. */
  193.  
  194. typedef const struct t30tabstruct
  195. { 
  196.   char *name ; 
  197.   u_char byte, shift, mask ; 
  198.   u_char captodis[8], distocap[16], captodcs[8], dcstocap[16] ; 
  199. } t30tabst ;
  200.  
  201. #define X 0xff                /* invalid values */
  202.  
  203. t30tabst t30tab [ NCAP ] = {
  204.   { "vr", 1, 1, 0x01, { 0, 1 } , { 0, 1 } , { 0, 1 } , { 0, 1 } },     
  205.   { "br", 1, 2, 0x0f, 
  206.       { 0, 4, 12, 12, 13, 13 } ,
  207.       { 0, X, X, X, 1, X, X, X, 3, X, X, X, 3, 5, 3, X } ,
  208.       { 0, 4, 12, 8, 5, 1 } ,
  209.       { 0, 5, 5, X, 1, 4, 4, X, 3, 7, X, X, 2, 6, X, X } } ,
  210.   { "wd", 2, 6, 0x03, { 0, 2, 1 } , { 0, 2, 1, 2 } ,
  211.       { 0, 2, 1 } , { 0, 2, 1, 2 } },
  212.   { "ln", 2, 4, 0x03, { 0, 2, 1 } , { 0, 2, 1, X } ,
  213.       { 0, 2, 1 } , { 0, 2, 1, X } },
  214.   { "df", 1, 0, 0x01, { 0, 1 } , { 0, 1 } , { 0, 1 } , { 0, 1 } },
  215.   { "ec", 3, 4, 0x03, { 0, 2, 2 } , { 0, X, 2, X } , 
  216.       { 0, 3, 2 } , { 0, 0, 2, 1 } }, 
  217.   { "bf", 5, 5, 0x01, { 0, 1 } , { 0, 1 } , { 0, 1 } , { 0, 1 } },
  218.   { "st", 2, 1, 0x07, 
  219.       { 7, 4, 3, 2, 6, 0, 5, 1 } , { 5, 7, 3, 2, 1, 6, 4, 0 } ,
  220.       { 7, 4, X, 2, X, 0, X, 1 } , { 5, 7, 3, 1, X, X, X, 0 } } 
  221. } ;
  222.  
  223.                     /* values of capability fields */
  224. const char *capvaluestr [ NCAP ] [8] = {
  225.   { " 98lpi", "196lpi" } , 
  226.   { " 2400bps", " 4800bps", " 7200bps", " 9600bps", "  12kbps", "14.4kbps",
  227.     "7200bpsV.17", "9600bpsV.17" } ,
  228.   { "8.5\"/215mm", " 10\"/255mm", " 12\"/303mm" } ,
  229.   { "11\"/A4", "14\"/B4", " any  " } ,
  230.   { "1D" , "2D" }, { "   -   ", "ECM-256", "ECM-64 " }, { " - ", "BFT" },
  231.   { "0ms", "5ms", "10/5ms", "10ms", "20/10ms", "20ms", "40/20ms", "40ms" }
  232. } ;
  233.  
  234. /* T.30 control frames */
  235.  
  236. enum frametype {        
  237.  DIS=0x01, CSI,    NSF=0x04,
  238.  CFR=0x21, FTT,
  239.  MCF=0x31, RTN, RTP, PIN, PIP,
  240.  DCS=0x41, TSI,    NSS=0x44,
  241.  CRP=0x58, DCN=0x5f,
  242.  EOM=0x71, MPS, EOP=0x074, PRI_EOM=0x79, PRI_MPS, PRI_EOP=0x7c,
  243.  DTC=0x80, CIG, NSC=0x84
  244.  } ;
  245.  
  246. /* Class 1 commands to [receive=0/transmit=1] [data=0/training=1] for
  247.    [baud rate=BR]. */
  248.  
  249. const char *c1cmd [ 2 ]  [ 2 ] [ 8 ] = { 
  250. { { "+FRM=24", "+FRM=48", "+FRM=72", "+FRM=96", "+FRM=122", "+FRM=146" ,
  251.     "+FRM=74", "+FRM=98" } ,
  252.   { "+FRM=24", "+FRM=48", "+FRM=72", "+FRM=96", "+FRM=121", "+FRM=145" ,
  253.     "+FRM=73", "+FRM=97" } } ,
  254. { { "+FTM=24", "+FTM=48", "+FTM=72", "+FTM=96", "+FTM=122", "+FTM=146" ,
  255.     "+FTM=74", "+FTM=98", } ,
  256.   { "+FTM=24", "+FTM=48", "+FTM=72", "+FTM=96", "+FTM=121", "+FTM=145" ,
  257.     "+FTM=73", "+FTM=97" } }
  258. } ;
  259.  
  260.  
  261. /* World's fastest T.4 decoder.  Implements a tree search.  Each bit of
  262.    each byte is tested using the T4TST(byte,bitmask) macro. This macro
  263.    invokes the macro T4CODE(len) when it detects a valid T.4 code or on the
  264.    first EOL after an invalid code.  The macro's parameter len will be the
  265.    run length, -1 on a normal EOL or -2 for the EOL following an error.  1D
  266.    coding only.
  267.  
  268.    As per T.4, run lengths >63 (make-up codes) should be added to the
  269.    subsequent (terminating) code.  The first run of a line is white and
  270.    colors alternate.
  271.  
  272.    Each node of the tree contains pointers to the next node for a '0' or a
  273.    '1' bit.  NULL pointers indicate terminal nodes in which case, the run
  274.    length (or -1 or -2) is given by the zlen or olen member and the search
  275.    continues with the node given by the znext or onext pointer.
  276.  
  277.    The decoding tree, stored in packed format (LSB to MSB plus guard bit),
  278.    is built by calling mktree() which returns a pointer to the initial
  279.    value of 't4p' to be used by the T4TST macro.
  280.  
  281. */
  282.  
  283. typedef struct dtree { 
  284.   struct dtree *zero, *one, *onext, *znext ; 
  285.   short int zlen, olen ;
  286. } dtree ;
  287.  
  288. #define T4TST(c,m) t4p = ( c & m ) ? \
  289. ( t4p->one  ? t4p->one  : ( T4CODE ( t4p->olen ), t4p->onext ) ) : \
  290. ( t4p->zero ? t4p->zero : ( T4CODE ( t4p->zlen ), t4p->znext ) ) ;
  291.  
  292. #define T4CTST(c) T4TST(c,0x80) ;  T4TST(c,0x40) ; \
  293.                   T4TST(c,0x20) ;  T4TST(c,0x10) ; \
  294.                   T4TST(c,0x08) ;  T4TST(c,0x04) ; \
  295.                   T4TST(c,0x02) ;  T4TST(c,0x01) ;
  296.  
  297. #define T4NODES 228
  298.  
  299. const short int pkdt4tree [] = {
  300.  
  301. 7,1,29,53,243,263,9,1,11,1,13,1,15,1,17,1,19,1,21,1,23,1,25,1,  
  302. 27,1,27,2,-2,31,49,43,33,75,35,37,4,10,121,39,41,173,4,63,4,0,  
  303. 79,45,95,47,93,4,1,71,51,167,4,2,55,61,57,59,4,3,67,69,4,4,63,65,  
  304. 4,5,83,4,6,4,7,2,128,4,8,4,9,87,73,109,4,11,89,77,99,4,12,117,  
  305. 103,81,107,4,13,85,2,64,4,14,4,15,4,16,4,17,119,91,203,4,18,4,19,127,  
  306. 97,131,4,20,129,137,101,143,4,21,123,105,145,4,22,4,23,147,111,155,  
  307. 113,115,4,24,149,151,4,25,153,4,26,4,27,163,4,28,165,209,125,  
  308. 4,29,4,30,4,31,4,32,4,33,4,34,133,135,4,35,4,36,4,37,4,38,139,141,  
  309. 4,39,4,40,4,41,4,42,4,43,4,44,4,45,4,46,4,47,4,48,4,49,4,50,4,51,4,52,  
  310. 4,53,4,54,157,2,192,159,161,4,55,4,56,4,57,4,58,4,59,4,60,4,61,4,62,  
  311. 175,169,181,171,197,2,256,2,320,2,384,2,1664,177,179,185,2,448,2,512,  
  312. 183,191,2,576,189,187,2,640,2,704,2,768,2,832,2,896,193,195,2,960,2,1024,  
  313. 2,1088,2,1152,199,201,2,1216,2,1280,2,1344,2,1408,205,207,2,1472,2,1536,  
  314. 2,1600,2,1728,235,211,213,217,215,223,2,1792,221,219,229,2,1856,2,1920,  
  315. 2,1984,2,2048,225,227,2,2112,2,2176,2,2240,2,2304,231,233,2,2368,2,2432,  
  316. 2,2496,2,2560,237,1,239,1,241,1,241,2,-1,245,261,247,265,249,267,  
  317. 273,251,271,253,255,2,12,281,257,303,259,307,2,0,2,1,2,4,2,3,2,2,  
  318. 2,6,2,5,269,2,7,2,9,2,8,2,10,2,11,291,275,277,279,2,13,283,287,2,14,  
  319. 2,15,299,313,285,383,2,16,289,309,2,17,357,423,293,295,321,297,317,  
  320. 2,18,363,327,301,331,2,19,305,341,2,20,339,2,21,349,333,311,347,2,22,  
  321. 315,351,2,23,361,379,319,389,2,24,323,371,325,367,2,25,397,395,329,  
  322. 2,26,2,27,2,28,2,29,335,337,2,30,2,31,2,32,2,33,2,34,2,35,343,345,  
  323. 2,36,2,37,2,38,2,39,2,40,2,41,2,42,2,43,353,355,2,44,2,45,2,46,2,47,  
  324. 359,393,2,48,2,49,2,50,2,51,365,377,2,52,403,399,369,401,2,53,  
  325. 373,4,64,375,409,2,54,407,405,2,55,381,387,2,56,415,385,391,2,57,2,58,  
  326. 417,2,59,2,60,419,2,61,4,256,2,62,2,63,4,128,4,192,421,4,320,  
  327. 4,384,4,448,4,512,4,576,4,640,4,704,4,768,4,832,4,896,4,960,411,413,  
  328. 4,1024,4,1088,4,1152,4,1216,4,1280,4,1344,4,1408,4,1472,4,1536,4,1600,  
  329. 4,1664,4,1728,449,425,427,431,429,437,4,1792,435,433,443,4,1856,4,1920,  
  330. 4,1984,4,2048,439,441,4,2112,4,2176,4,2240,4,2304,445,447,4,2368,4,2432,  
  331. 4,2496,4,2560,451,1,453,1,455,1,455,2,-1,
  332. -1 } ;
  333.  
  334.  
  335. /* Program options. Not changed except in main(). */
  336.  
  337. cap local = { DEFCAP } ;      /* -c  local capabilities */
  338. char *argv0 = "?" ;          /*     program name (argv[0]) */
  339. char *fnamepat= FNAMFT ;      /* -r  pattern for received file names */
  340. char **fnames = 0 ;          /* -t  files to send */
  341. char *getty = "" ;          /* -g  command for data calls */
  342. char *iopt[ MAXIOPT ] ;          /* -i  modem init commands */
  343. char *zopt[ MAXIOPT ] ;          /* -z  modem reset commands */
  344. char *lkfiles [ MAXLKFILE+1 ] ;      /* -x  lock files  */
  345. char localid  [ IDLEN + 1 ] ;      /* -l  local ID (telephone #) */
  346. char *verb = "ewin" ;          /* -v  verbosity level */
  347. int c1 = 0 ;              /* -o1 use class 1 protocol */
  348. int softadans = 0 ;          /* -oa use software adaptive answer */
  349. int igniniterr=0 ;          /* -oe ignore initialization errors */
  350. int niopt=0 ;              /*     number of init commands */
  351. int nzopt=0 ;              /*     number of reset commands */
  352. int cmdpause = T_CMD ;          /* -oz delay before each init command */
  353. int maxpgerr = 10 ;          /* -q  maximum errors per page */
  354. int nfiles=0 ;              /*     number of files to send */
  355. int share = 0 ;              /* -s  share fax device */
  356. int waitforcall = 0 ;          /* -w  wait for incoming call */
  357. u_char startchar = DC2 ;      /* -ox character to start reception */
  358.  
  359.  
  360.  
  361. /* Bit ordering: serial devices transmit LS bit first.  T.4/T.30 says MS
  362.    bit is sent first. `Normal' order therefore reverses bit order. */
  363.  
  364. u_char                           /* bit reversal lookup tables*/
  365.    reversebits [ 256 ] , normalbits [ 256 ] , 
  366.    *rxbitorder = normalbits , *txbitorder = normalbits ;
  367.  
  368. dtree *t4tree ;                /* T.4 decoding tree */
  369.  
  370. /* fax stream variables (private). */
  371.  
  372. u_char faxibuf [ RCVBUFSIZE ] ,        /* fax input stream. */
  373.   *faxip=faxibuf , *faxiq=faxibuf ;
  374.  
  375. u_char faxobuf [ SNDBUFSIZE ] ,        /* fax output stream. */
  376.   *faxop=faxobuf , *faxoq=faxobuf+SNDBUFSIZE ;
  377.  
  378. int faxdev=-1 ;                /* fax device file descriptor. */
  379.  
  380. /* session state variables. */
  381.  
  382. FILE *file=0 ;                /* current image file  */
  383. cap remote ;                            /* remote capabilities  */ 
  384. cap session ;                        /* session capabilities */
  385. char remoteid [ IDLEN + 1 ] ;        /* ID (tel no) of remote station */
  386. int crate = 19200 ;                /* CONNECT rate */
  387. int datamode=0 ;            /* true if answered in data mode */
  388. int decimate = 0 ;            /* drop 1/2 lines to get 98 lpi */
  389. int good=1 ;                /* page received OK */
  390. int hsc=-1 ;                /* hangup status code (Class 2) */
  391. int minlen = 0 ;            /* pad lines to this many bytes */
  392.  
  393.  
  394. /* Functions... */
  395.  
  396. /* Print time stamp. */
  397.  
  398. void tstamp( )
  399. {
  400.   static time_t last = 0 , now ;
  401.   char *fmt = 0, tbuf [ MAXTSTAMP ] ;
  402.  
  403.   now = time ( 0 ) ;
  404.  
  405.   if ( now - last >   0 ) fmt = " (%M:%S)" ;
  406.   if ( now - last > 600 ) fmt = " %c" ;
  407.  
  408.   if ( fmt ) {
  409.     strftime ( tbuf , MAXTSTAMP , fmt , localtime( &now ) ) ;
  410.     fputs ( tbuf , LOGF ) ;
  411.     last = now ; 
  412.   }
  413. }
  414.  
  415.  
  416. /* For systems without strerror(3) */
  417.  
  418. char *strerror( int i )       
  419. {
  420.   extern int sys_nerr;
  421.   extern char *sys_errlist[];
  422.   return ( i >= 0 && i < sys_nerr ) ? sys_errlist[i] : "Unknown Error" ;
  423. }
  424.  
  425.  
  426. /* Return string corresponding to character c. */
  427.  
  428. char *cname ( u_char c ) 
  429. {
  430. #define CNAMEFMT "<0x%02x>"
  431. #define CNAMELEN 6+1
  432.   static char *cname [ 256 ] = {        /* character names */
  433.   "<NUL>","<SOH>","<STX>","<ETX>", "<EOT>","<ENQ>","<ACK>","<BEL>",
  434.   "<BS>", "<HT>", "<LF>", "<VT>",  "<FF>", "<CR>", "<SO>", "<SI>", 
  435.   "<DLE>","<XON>","<DC2>","<XOFF>","<DC4>","<NAK>","<SYN>","<ETB>",
  436.   "<CAN>","<EM>", "<SUB>","<ESC>", "<FS>", "<GS>", "<RS>", "<US>" } ;
  437.   static char names[ (127-32)*2 + 129*(CNAMELEN) ], *p=names ;
  438.   static int i=0 ;
  439.     
  440.   if ( ! i ) 
  441.     for ( i=32 ; i<256 ; i++ ) {
  442.       cname [ i ] = p ;
  443.       sprintf ( p, i<127 ? "%c" : CNAMEFMT , i ) ;
  444.       p += strlen ( p ) + 1 ;
  445.     }
  446.  
  447.   return cname [ c ] ;
  448. } 
  449.  
  450. /* Return name of frame of type 'fr'. */
  451.  
  452. const char *frname ( int fr )
  453. {
  454. static struct framenamestruct {  int code ;  const char *name ; } 
  455. framenames [] = {
  456.  {DIS,"DIS"},{CSI,"CSI"},{NSF,"NSF"},{CFR,"CFR"},{FTT,"FTT"},{MCF,"MCF"},
  457.  {RTN,"RTN"},{RTP,"RTP"},{PIN,"PIN"},{PIP,"PIP"},{DCS,"DCS"},{TSI,"TSI"},
  458.  {NSS,"NSS"},{CRP,"CRP"},{DCN,"DCN"},{EOM,"EOM"},{MPS,"MPS"},{EOP,"EOP"},
  459.  {PRI_EOM,"PRI-EOM"},{PRI_MPS,"PRI-MPS"},{PRI_EOP,"PRI-EOP"},
  460.  {DTC,"DTC"},{CIG,"CIG"},{NSC,"NSC"}, {0,0} }, *p ;
  461.  
  462.   for ( p=framenames ; p->code && p->code != fr ; p++ ) ;
  463.   return p->code ? p->name : "UNKNOWN" ;
  464. }
  465.  
  466.  
  467. /* Print a message with a variable number of printf()-type arguments if the
  468.    first character appears in the verb[ose] string.  Other leading
  469.    characters and digits do additional actions: + allows the message to be
  470.    continued on the same line, '-' buffers the message instead of printing
  471.    it, E, and W expand into strings, S prints the error message for the
  472.    most recent system error, 0-4 set the return value, a space is skipped
  473.    and ends prefix.  Returns 0 if no prefix digit. */
  474.  
  475. int msg ( const char *fmt, ... ) 
  476. { 
  477.   int err=0, dolf=1, flush=1 ;
  478.   char *ps="", *pe="", *pw="" ;
  479.   const char *p ;
  480.   static int atcol1=1 ;
  481.   va_list ap ;
  482.   va_start ( ap, fmt ) ;
  483.  
  484.   for ( p=fmt ; *p ; p++ ) {
  485.     switch ( *p ) {
  486.     case ' ': p++ ; goto print ;
  487.     case 'A': break ;                   /* program args */
  488.     case 'C': break ;                   /* commands/responses */
  489.     case 'M': break ;                   /* modem dialogue */
  490.     case 'N': break ;                   /* negotiation */
  491.     case 'E': pw = "Error: " ; break ;
  492.     case 'H': break ;                   /* HDLC frame data */
  493.     case 'I': break ;                   /* information */
  494.     case '+': dolf = 0 ; break ;
  495.     case '-': flush = 0 ; break ;
  496.     case 'R': break ;                   /* reception errors */
  497.     case 'S': ps = strerror ( errno ) ; break ;
  498.     case 'W': pw = "Warning: " ; break ;
  499.     case '0': case '1': case '2': case '3': case '4': case '5': 
  500.       err = *p - '0' ; break ;
  501.     default: goto print ;
  502.     }
  503.   }
  504.  
  505.   print:  
  506.   if ( strchr ( verb , tolower ( *fmt ) ) ) {
  507.     if ( atcol1 ) fprintf ( LOGF , "%s: %s%s" , argv0 , pe , pw ) ;
  508.     vfprintf( LOGF, p , ap ) ;
  509.     fputs ( ps , LOGF ) ;
  510.     if ( ( atcol1 = dolf ) ) {
  511.       tstamp ( ) ; 
  512.       fputs ( "\n" , LOGF ) ;
  513.     }
  514.     if ( flush ) fflush ( LOGF ) ;
  515.   }
  516.  
  517.   va_end ( ap ) ;
  518.   return err ;
  519. }
  520.  
  521.  
  522. /* Unpack the decoding tree. If the LS bit is 1, the entry is a
  523.    pointer to the next node in a code word, else it is a terminal
  524.    node and the value is a pointer to where to continue scanning
  525.    for the next code word and the following value is the run
  526.    length (or -1 or -2). */
  527.  
  528. dtree *unpktree ( )
  529. {
  530.   static dtree nodes [ T4NODES ], *p ;
  531.   const short int *l ;
  532.   for ( p=nodes, l=pkdt4tree ; *l > 0 ; p++ ) {
  533.     if ( p - nodes >= T4NODES ) {
  534.       fprintf ( stderr, "error in T.4 decoding tree\n" ) ; break ;
  535.     }
  536.     if ( *l & 1 ) { p->zero = nodes + *l++/2 ; }
  537.     else { p->znext = nodes + *l++/2 ; p->zlen = *l++ ; } ;
  538.     if ( *l & 1 ) { p->one  = nodes + *l++/2 ; } 
  539.     else { p->onext = nodes + *l++/2 ; p->olen = *l++ ; } ;
  540.   }
  541.   return nodes + 1 ;        /* search starts at node 1 (white runs) */
  542. }
  543.  
  544.  
  545. /* millisecond delays (for systems without usleep). */
  546.  
  547. void msleep ( int t )
  548. {
  549.   struct timeval timeout ;
  550.   timeout.tv_sec  = t / 1000 ; 
  551.   timeout.tv_usec = ( t % 1000 ) * 1000 ;
  552.   if ( select ( 1 , 0 , 0 , 0 , &timeout ) < 0 ) 
  553.     msg ("ES2select failed in msleep:") ;
  554. }
  555.  
  556. /* Return number of characters ready to read or < 0 on error.  t
  557.    is tenths of a second of idle time before timing out.  If t is
  558.    negative, waits forever. */
  559.  
  560. int faxdata ( int t )
  561. {
  562.   int n ;
  563.   fd_set fds ;
  564.  
  565.   struct timeval timeout ;
  566.  
  567.   if ( faxdev < 0 ) msg ("Ecan't happen (faxdata)") ;
  568.  
  569.   timeout.tv_sec  = t / 10 ; 
  570.   timeout.tv_usec = ( t % 10 ) * 100000 ;
  571.  
  572.   FD_ZERO ( &fds ) ;
  573.   FD_SET ( faxdev , &fds ) ;
  574.  
  575.   n = select ( faxdev+1 , &fds , 0 , 0 , t<0 ? 0 : &timeout ) ;
  576.   if ( n < 0 ) msg("ES2select failed in faxdata:") ;
  577.  
  578.   return n ;
  579. }
  580.  
  581. /* faxundrflw is called only by the faxgetc() macro when the buffer is
  582.    empty.  t is maximum idle time before giving up. Returns number of
  583.    characters read or EOF on timeout or errors.  */
  584.  
  585. int faxundrflw ( int t )
  586. { 
  587.   int n = faxdata ( t ) ;
  588.  
  589.   if ( n > 0 )
  590.     if ( ( n = read( faxdev , faxibuf , RCVBUFSIZE ) ) < 0 ) 
  591.       msg ("ES2fax device read:") ;
  592.  
  593.   faxiq = ( faxip = faxibuf ) + ( n > 0 ? n : 0 ) ;
  594.  
  595.   return n > 0 ? n : EOF ;
  596. } 
  597.  
  598. /* faxgetc is a macro like getc().  It returns the next character
  599.    from the fax device or EOF after idle time t. */
  600.  
  601. #define faxgetc(t) ( faxip >= faxiq && faxundrflw(t) == EOF ? EOF : \
  602.             *(u_char*)faxip++ )
  603.  
  604. /* A function like faxgetc that also removes DLE escapes, detects DLE-ETX
  605.    terminators and fixes bit order. Does not ignore invalid escape
  606.    sequences. Returns the character read, EOF on error/timeout, or -2 on
  607.    DLE-ETX.  */
  608.  
  609. int faxgetdatac ( int t )
  610. {
  611.   int c ;
  612.   return ( c = faxgetc(t) ) == DLE && ( c = faxgetc(t) ) == ETX ? -2 : 
  613.     normalbits [ c & 0xff ] ;
  614. }
  615.  
  616.  
  617. /* Get a modem response into buffer s, storing up to n bytes.  The response
  618.    begins with most recent non-control character and ends with CR/LF.
  619.    Returns s or null if times-out in t deciseconds or on i/o error. Trace
  620.    messages are buffered to reduce possible timing problems. */
  621.  
  622. char *faxgets( char *s , int n , int t )
  623. {
  624.   int c=0, sta=0 ;
  625.   char *p = s ;
  626.  
  627.   while ( sta < 4 ) {
  628.     if ( ( c = faxgetc( t ) ) == EOF ) break ;
  629.     c &= 0x7f ;
  630.     if ( ! sta ) msg ( "M-+ [" ) ; 
  631.     msg ( "M-+ %s" , cname ( c ) ) ;
  632.     switch ( sta ) {
  633.     case 0 :
  634.     case 1 : sta =               ( iscntrl ( c ) ? 1 : (p=s, 2) ) ; break ;
  635.     case 2 : sta = c == CR ? 3 : ( iscntrl ( c ) ? 1 :       2  ) ; break ;
  636.     case 3 : sta = c == LF ? 4 : ( iscntrl ( c ) ? 1 : (p=s, 2) ) ; break ;
  637.     default: msg ( "Ecan't happen (faxgets)" ) ;
  638.     }
  639.     if ( sta == 2 && p < s+n-1 ) *p++ = c ;
  640.   }
  641.  
  642.   *p = 0 ;
  643.   if ( p >= s+n-1 ) msg ( "W- modem response overflow" ) ;
  644.   if ( sta ) msg ( "M- %s]" , c == EOF ? "<timeout>" : "" ) ;
  645.  
  646.   return c == EOF ? 0 : s ;
  647. }
  648.  
  649.  
  650. /* Write the fax output buffer to fax output device. To allow zero-fill
  651.    underflow padding, should be called after writing the EOL zero
  652.    byte. Warns if called with full buffer (presumably called from
  653.    faxputc()). Returns 0 or EOF on error. */
  654.  
  655. int faxflush ( )
  656. { 
  657.   int n=0 ;
  658.   u_char *p = faxobuf ;
  659.  
  660.   if ( faxdev < 0 ) msg ("Ecan't happen (faxflush)") ;
  661.  
  662.   if ( faxop >= faxoq ) msg ("Wfax output buffer overflow") ;
  663.  
  664.   while ( p < faxop && ( n = write( faxdev , p , faxop - p ) ) >= 0 )
  665.     p += n ? n : msg ( "W0wrote %d of %d bytes" , n , faxop - p ) ;
  666.  
  667.   return n >= 0 ? (faxop = faxobuf , 0) : (msg ("ESfax device write:") , EOF) ;
  668. } 
  669.  
  670. /* faxputc() is a macro like putc().  It returns the character written or
  671.    EOF on error. */
  672.  
  673. #define faxputc(c) ( faxop >= faxoq && faxflush() == EOF ? EOF : \
  674.             (u_char) ( *faxop++ = (c) ) )
  675.  
  676. /* faxobytes() returns number of bytes in fax output buffer */
  677.  
  678. #define faxobytes() ( faxop - faxobuf ) 
  679.  
  680.  
  681. /* A function like faxputc but also escapes DLEs and sets proper bit
  682.    order. */
  683.  
  684. int faxputdatac ( u_char c )
  685. {
  686.   int x ;
  687.   x  = normalbits [ c ] ;
  688.   if ( x == DLE ) x = faxputc ( x ) ;
  689.   return x < 0 ? x : faxputc ( x ) ;
  690. }
  691.  
  692.  
  693. /* Send character or string to modem immediately (for commands).  Returns
  694.    like putc() and puts(). */
  695.  
  696. int faxputcnow ( char c ) 
  697. { 
  698.   return faxputc ( c ) < 0 ? EOF : ( faxflush() ? EOF : c ) ; 
  699. }
  700.  
  701. int faxputs ( const char *s )
  702. {
  703.   int n=0 ;
  704.   while ( s && *s && ( n = faxputcnow ( *s++ ) ) != EOF ) ;
  705.   return n ;
  706. }
  707.  
  708.  
  709. /* Compare current termios state with termios struct t. Returns 0 if equal,
  710.    1 otherwise. */
  711.  
  712. int checktermio ( struct termios *t )
  713. {
  714.   struct termios s ;
  715.   return tcgetattr ( faxdev , &s ) != 0 ||
  716.     t->c_iflag != s.c_iflag || t->c_oflag != s.c_oflag
  717.       || t->c_lflag != s.c_lflag || t->c_cflag != s.c_cflag
  718.     || t->c_cc[VMIN] != s.c_cc[VMIN] || t->c_cc[VTIME]!= s.c_cc[VTIME] ;
  719. }
  720.  
  721.  
  722. /* Set serial port mode. First time through saves initial settings. Sets
  723.    raw, 8-bit, 19.2 kbps mode with no flow control or as required. Returns
  724.    0 or 2 on error. */
  725.  
  726. int ttymode ( enum ttymodes mode )
  727. {
  728.   int err=0 ;         
  729.   static int saved=0 ;
  730.   static struct termios old, t ;
  731.  
  732.   if ( faxdev < 0 ) msg ("Ecan't happen (ttymode/faxdev)") ;
  733.  
  734.   tcdrain ( faxdev ) ;
  735.   tcflush ( faxdev , TCIOFLUSH ) ; /* make sure */
  736.  
  737.   if ( ! saved ) { 
  738.     if ( tcgetattr ( faxdev , &t ) ) {
  739.       err = msg ("ES2tcgetattr failed:") ;
  740.     } else {
  741.       old = t ; 
  742.       saved = 1 ;
  743.     } 
  744.   } else {
  745.     if ( checktermio ( &t ) ) msg ( "Wterminal mode corrupted" ) ;
  746.   }
  747.  
  748.   t.c_iflag = IGNBRK | IGNPAR | IXANY ;
  749.   t.c_oflag = 0 ;
  750.   t.c_cflag = CS8 | CREAD | CLOCAL | HUPCL ;
  751.   t.c_lflag = 0 ;
  752.   
  753.   t.c_cc[VMIN]  = 1 ; 
  754.   t.c_cc[VTIME] = 0 ; 
  755.  
  756.   cfsetospeed ( &t , B19200 ) ; 
  757.   cfsetispeed ( &t , B19200 ) ; 
  758.  
  759.   if ( ! err ) 
  760.     switch ( mode ) {
  761.     case  COMMAND :                                         break ;
  762.     case  DROPDTR : cfsetospeed ( &t , B0 ) ;               break ;
  763.     case     SEND : t.c_iflag |= IXON ;                     break ;
  764.     case ORIGINAL : if ( saved ) t = old ;                  break ;
  765.           default : err = msg ("E2can't happen(ttymode)") ; break ;
  766.     }
  767.   
  768.   tcdrain ( faxdev ) ;        /* make *sure* output done B4 turn off f/c */
  769.   tcflow ( faxdev , TCOON ) ;    /* in case XON got lost */
  770.  
  771.   if ( ! err && tcsetattr ( faxdev , TCSANOW , &t ) )
  772.     err = msg ( "ES2tcsetattr failed:" ) ;
  773.  
  774.   if ( !err && checktermio ( &t ) ) 
  775.     err = msg ( mode == ORIGINAL ? 
  776.            "W0terminal mode not restored properly" : 
  777.            "E2terminal mode not set properly" ) ;
  778.   
  779.   return err ;
  780. }
  781.  
  782.  
  783. /* Convert capability string to cap struct. Returns 0 or 2 on errors. */
  784.  
  785. int str2cap ( char *s, cap c )
  786. {
  787.   int err=0, i=0, n ;
  788.   char *p ;
  789.  
  790.   for ( n=0, p=s ; ! err && *p && i<NCAP ; p++ )
  791.     if ( isdigit ( *p ) ) c [ n++ ] = *p - '0' ;
  792.     else if ( isspace ( *p ) || *p == ',' ) ;
  793.     else err = msg ("E2invalid character (%c) in (%s)", *p , s ) ;
  794.  
  795.   if ( n < NCAP ) msg ( "W0missing value(s) in capability \"%s\"", s ) ;
  796.  
  797.   for ( i=0 ; i<n ; i++ ) 
  798.     if ( c [ i ] > capmax [ i ] || c [ i ] < 0 ) 
  799.       err = msg ( "E2%s = %d is %s", s , t30tab[i].name , c [ i ], 
  800.         c[i]<0 ? "negative" : "too big" ) ;
  801.   
  802.   return err ;
  803. }
  804.  
  805. /* Print cap[ability] 'c' using text values and prefix 's'. */
  806.  
  807. void printcap ( char *s , cap c )
  808. {
  809.   int i ;
  810.   msg ( "N-+ %s" , s ) ;
  811.   for ( i=0 ; i<NCAP ; i++ ) 
  812.     msg ( "N-+  %s" , c[i] > capmax [ i ] || c[i] < 0 ?  "ERROR" :
  813.      capvaluestr [ i ] [ c[i] ] ) ;
  814.   msg ( "N-" , s ) ;
  815. }
  816.  
  817.  
  818. /* Convert a cap[ability] 'c' to a DIS/DCS/DTC FIF 'fif' of 'len' bytes.
  819.    Converts into DIS format if 'isdis' is true, else into DCS/DTC
  820.    format. Returns 0 or 3 on internal error (bad conversion tables). */
  821.  
  822. int mkdis ( cap c , u_char *fif , int len , int isdis ) 
  823. {
  824.   int err=0, i, j, k ;
  825.   t30tabst *p ;
  826.  
  827.   if ( len < 3 || len > 5 ) 
  828.     len = msg ( "W3bad DCS/DIS length (%d) set to 3" , len ) ;
  829.  
  830.   fif[0] = 0 ;
  831.   fif[1] = isdis ? 0xc0 : 0x40 ;
  832.   for ( i=2 ; i<len-1 ; i++ ) fif[i] = 0x01 ;       /* add extension bits */
  833.   fif[i] = 0 ;
  834.  
  835.   for ( i=0 ; p=t30tab+i, i<NCAP ; i++ ) {
  836.  
  837.     j = c [ i ] ;
  838.     if ( j > capmax [ i ] || j < 0 ) {
  839.       j = 0 ;
  840.       err = msg ( "E3mkdis: bad %s = %d set to 0", p->name, j ) ;
  841.     }
  842.     k = ( isdis ? p->captodis : p->captodcs ) [ j ] ;
  843.     if ( k == X ) {
  844.       k = 0 ;
  845.       err = msg ( "E3mkdis: can't happen (invalid %s)", p->name ) ;
  846.     }
  847.     if ( p->byte < len ) fif [ p->byte ] |=  k << p->shift ;
  848.   }
  849.   return err ;
  850. }
  851.  
  852. /* Return length of DIS/DTC FIF (counts extension bits). */
  853.  
  854. int dislen ( u_char *fif )
  855. {
  856.   int n ;
  857.   for ( n=3 ; fif [ n-1 ] & 0x01 ; n++ ) ;
  858.   return n ;
  859. }
  860.  
  861. /* Convert received DIS/DCS/DTC FIF to cap. Returns 0 or 3 on error (bad
  862.    DIS/DCS field). */
  863.  
  864. int mkcap ( u_char *fif, cap c , int dis ) 
  865. {
  866.   int err=0, i, j, k, len ;
  867.   t30tabst *p ;
  868.  
  869.   len = dislen ( fif ) ;
  870.  
  871.   for ( i=0 ; i<NCAP ; i++ ) {
  872.     p=t30tab+i ;
  873.     if ( p->byte >= len ) {
  874.       c [ i ] = 0 ;
  875.     } else {
  876.       j = fif [ p->byte ] >> p->shift & p->mask ;
  877.       k = ( dis ? p->distocap : p->dcstocap ) [ j ] ;
  878.       if ( k == X ) {
  879.     c [ i ] = 0 ;
  880.     err = msg("E3mkcap: bad %s field (%d) set to 0", p->name, j) ;
  881.       } else { 
  882.     c [ i ] = k ;
  883.       }
  884.     }
  885.   }
  886.   return err ;
  887. }
  888.  
  889.  
  890. /* Compute compatible local/remote capabilities. As side effect, sets
  891.    minimum line length and decimation. This routine is used by the sending
  892.    station only (or both in Class 2). Returns 0 if OK or 3 if no compatible
  893.    settings possible. */
  894.  
  895. int mincap ( cap local, cap remote, cap session )
  896. {
  897.   int err=0, i ;
  898.   int msttab[2][8] = { { 0,1,3,3,5,5,7,7 } , { 0,1,1,3,3,5,5,7 } } ;
  899.  
  900.   for ( i=0 ; i<NCAP && i!=ST ; i++ )
  901.     session[i] = remote[i] < local[i] ? remote[i] : local[i] ;
  902.  
  903.   session[ST] = msttab [ session[VR] ] [ remote[ST] ] ;
  904.  
  905.   minlen = (cps[session[BR]] * delay[session[ST]] + 500) / 1000 ;
  906.  
  907.   decimate = local[VR] == 1 && session[VR] == 0 ;
  908.  
  909.   printcap ( "local  ", local ) ;
  910.   printcap ( "remote ", remote ) ;
  911.   printcap ( "session", session ) ;
  912.   msg ( "N- padding to %d bytes/line.%s", minlen, 
  913.        decimate ? " reducing 198->96 lpi." : "" ) ;
  914.  
  915.   if ( local[WD] != session[WD] || local[LN] != session[LN] || 
  916.       local[DF] != session[DF] ) 
  917.     err = msg ("E3can't convert image to remote capabilities" ) ;
  918.  
  919.   return err ;
  920. }
  921.  
  922.  
  923. /* Search for a match to the string s in a null-terminated array of
  924.    possible prefix strings pointed to by p.  The first character of each
  925.    prefix string is skipped.  Returns pointer to the table entry or NULL if
  926.    not found.  */
  927.  
  928. char *strtabmatch ( char **p, char *s )
  929. {
  930.   while ( *p && strncmp ( *p+1 , s , strlen ( *p+1 ) ) ) p++ ;
  931.   return ( ! *p || **p == '-' ) ? NULL : *p ;
  932. }
  933.  
  934.  
  935. /* Send command to modem and check responses.  Collects pending
  936.    (unexpected) responses and then pauses for inter-command delay
  937.    (cmdpause) if t is negative.  Writes command s to modem if s is not
  938.    null.  Reads responses and terminates when a response is one of the
  939.    prompts in responses[] or if times out in t deciseconds.  Notes and
  940.    processes important class 2 responses (FPTS: Page Transfer Status, FHNG:
  941.    HaNGup status, and FDCS: Current Session capabilities).  Repeats command
  942.    if detects a RING response (probable collision). Returns the first
  943.    character of the matching prefix string (e.g. 'O' for OK, 'C' for
  944.    CONNECT, etc.)  or EOF if no such response was received within timeout
  945.    t. */
  946.  
  947. int cmd ( const char *s , int t )
  948. {
  949.   char buf [ CMDBUFSIZE ] , *p = "" ;
  950.   int ppr ;
  951.  
  952.  retry:
  953.  
  954.   while ( s && faxgets ( buf , CMDBUFSIZE , t<0 ? cmdpause : 0 ) )
  955.     msg ( "W- unexpected response \"%s\"", buf ) ;
  956.  
  957.   msg ( s ? "C- command  \"%s\"" : "C- waiting" , s ) ;
  958.  
  959.   if ( s ) { faxputs ( "AT" ) ; faxputs ( s ) ; faxputcnow ( CR ) ; }
  960.  
  961.   while ( t && ( p = faxgets( buf , CMDBUFSIZE , t<0 ? -t : t ) ) ) {
  962.  
  963.     msg ( "C- response \"%s\"" , p ) ;
  964.  
  965.     if ( ! strncmp ( buf, "DATA" , 4 ) ||
  966.     ! strncmp ( buf, "CONNECT DATA" , 12 ) )
  967.       datamode = 1 ;
  968.     if ( ! strncmp ( buf, "+FDCS:", 6 ) && ! str2cap ( buf+6 , session ) ) 
  969.       mincap ( local, session, session ) ; /* set decimation & minlen */
  970.     if ( sscanf ( buf , "+FPTS: %d", &ppr ) > 0 ) good = ppr & 1 ;
  971.     sscanf ( buf, "+FHNG: %d", &hsc ) ;
  972.     sscanf ( buf, "CONNECT %d", &crate ) ;
  973.  
  974.     if ( ( p = strtabmatch ( (char**) prompts , buf ) ) ) break ;
  975.  
  976.     if ( ! strncmp ( buf, "RING", 4 ) ) { msleep(100) ; goto retry ; }
  977.   }
  978.  
  979.   return p ? *p : EOF ;
  980. }
  981.  
  982. /* Send command to modem and wait for either of two possible replies after
  983.    testing (and possibly setting) current error status via err pointer. */
  984.  
  985. void ckcmd ( int *err, const char *s, int t, int r1, int r2 )
  986. {
  987.   int c ;
  988.   if ( ! *err )
  989.     if ( ( c = cmd ( s, t ) ) != r1 && c != r2 ) 
  990.       if ( c == EOF ) 
  991.     *err = msg ("E3modem command (%s) timed out", s ? s : "none" ) ;
  992.       else
  993.     *err = msg ("E3wrong response to command (%s)", s ? s : "none" ) ;
  994. }
  995.  
  996.  
  997. /* Test for UUCP lock file & remove stale locks. Returns 0 on null file
  998.    name or if no longer locked, 1 if locked by another pid, 2 on error, 3
  999.    if locked by us. */
  1000.  
  1001. int ttlocked ( char *fname )
  1002. {
  1003.   int err=0 ;
  1004.   FILE *f ;
  1005.   pid_t pid = 0 ;
  1006.   char buf [ FILENAME_MAX ] = "" ;
  1007.  
  1008.   if ( fname && *fname == HDBLKFLAG ) fname++ ;
  1009.  
  1010.   if ( fname && ( f = fopen ( fname , "r" ) ) ) {
  1011.     if ( fread ( buf, sizeof(char), FILENAME_MAX-1, f )  == sizeof(pid_t) || 
  1012.     sscanf ( buf , "%d" , &pid ) != 1 ) pid = * (pid_t *) buf ;
  1013.     if ( kill ( pid , 0 ) && errno == ESRCH )
  1014.       if ( unlink ( fname ) ) err = 
  1015.     msg ( "ES2can't remove stale lock %s from pid %d:" , fname , pid ) ;
  1016.       else err = 
  1017.     msg ( "I0removed stale lock %s from pid %d" , fname , pid ) ;
  1018.     else 
  1019.       if ( pid != getpid() ) err = 1 ;
  1020.       else err = 3 ; 
  1021.     fclose ( f ) ;
  1022.   }
  1023.   return err ;
  1024. }
  1025.  
  1026. /* Create UUCP (text or binary) lock file.  Returns 0 on null
  1027.    file name or if created, 1 if locked by another pid, 2 on
  1028.    error, 3 if locked by us. */
  1029.  
  1030. int ttlock ( char *fname )
  1031. {
  1032.   int err=0, dirlen, hdb=0 ;    
  1033.   FILE *f=0 ;    
  1034.   pid_t pid = getpid ( ) ;
  1035.   char *p , buf [ FILENAME_MAX ] = "" ;
  1036.  
  1037.   if ( fname && *fname == HDBLKFLAG ) { fname++ ; hdb=1 ; }
  1038.  
  1039.   if ( fname && ! ( err = ttlocked ( fname ) ) ) {
  1040.     dirlen = ( p = strrchr( fname , '/' ) ) ? p-fname+1 : strlen ( fname ) ;
  1041.     sprintf ( buf , "%.*sTMP..%05d" , dirlen , fname , pid ) ;
  1042.     if (  ( f = fopen( buf, "w" ) )  && 
  1043.     ( hdb ? 
  1044.      (fprintf(f, "%10d\n", pid)>0) : fwrite(&pid, sizeof(pid_t), 1, f) )
  1045.     ) {
  1046.       if ( rename ( buf , fname ) == 0 ) chmod ( fname , 0444 ) ;
  1047.       else if ( ! ( err = ttlocked ( fname ) ) )
  1048.     err = msg ( "ES2can't rename lock file %s to %s:\n", buf, fname ) ;
  1049.     } else {
  1050.       err = msg ( "ES2can't open/write pre-lock file %s:\n", buf ) ;
  1051.     }
  1052.   }
  1053.   if ( f ) { fclose ( f ) ; if ( err ) unlink ( buf ) ; }
  1054.   return err ;
  1055. }
  1056.  
  1057.  
  1058. /* Remove lock file.  Returns 0 on null file name, doesn't exist, or was
  1059.    removed, 1 if the lock is to another pid, 2 on errors. */
  1060.  
  1061. int ttunlock ( char *fname )
  1062. {
  1063.   int err = 0 ;
  1064.  
  1065.   if ( fname && *fname == HDBLKFLAG ) { fname++ ; }
  1066.  
  1067.   if ( fname && ( err = ttlocked ( fname ) ) ) {
  1068.     if ( err == 1 ) msg ( "Ewon't remove lock %s (not ours)" , fname ) ;
  1069.     if ( err == 3 )
  1070.       if ( unlink ( fname ) ) err = msg ( "ES2can't remove lock %s:", fname ) ;
  1071.       else err = 0 ;
  1072.   }
  1073.   return err ;
  1074. }
  1075.  
  1076.  
  1077. /* Lock all lock files.  Returns 0 if all locks [already] applied, 1 if any
  1078.    are locked to other pids, 2 on any errors. */
  1079.  
  1080. int lockall ( )
  1081. { 
  1082.   int err = 0 ;
  1083.   char **p = lkfiles ;
  1084.   while ( *p && ! err ) 
  1085.     if ( ( err = ttlock ( *p++ ) ) == 3 ) err = 0 ; 
  1086.   return err ; 
  1087. }
  1088.  
  1089. /* Remove all lock files.  Returns 0 if all locks removed, 2 on errors. */
  1090.  
  1091. int unlockall ( )
  1092. { 
  1093.   int err = 0 ;
  1094.   char **p = lkfiles ;
  1095.   while ( *p ) if ( ttunlock ( *p++ ) ) err = 2 ; 
  1096.   return err ; 
  1097. }
  1098.  
  1099. /* Resynchronize modem from an unknown state.  If no immediate response,
  1100.    try pulsing DTR low (needs &D{2,3,4}), and cancelling data or fax data
  1101.    modes.  In each case, discard any responses for about 2 seconds and then
  1102.    try command s.  Returns 0 if OK or 4 if no response.  */
  1103.  
  1104. int faxsync( char *s )
  1105. {
  1106.   int err=0, method=0 ;
  1107.  
  1108.   while ( ! err ) {
  1109.     switch ( method++ ) {
  1110.     case 0 : 
  1111.       break ;
  1112.     case 1 : 
  1113.       msg ("Isync: dropping DTR") ;
  1114.       ttymode ( COMMAND ) ; msleep ( 200 ) ;
  1115.       ttymode ( DROPDTR ) ; msleep ( 200 ) ;
  1116.       ttymode ( COMMAND ) ; 
  1117.       break ;
  1118.     case 2 : 
  1119.       msg ("Isync: sending escape") ;
  1120.       faxputs ( DLE_ETX ) ; 
  1121.       msleep ( 1500 ) ;
  1122.       faxputs ( "+++" ) ; 
  1123.       break ;
  1124.     case 3 :
  1125.       err = msg ("E4sync: modem not responding") ;
  1126.       continue ;
  1127.     }
  1128.     while ( cmd ( 0 , method ? TO_RESET : 1 ) != EOF ) ;
  1129.     if ( cmd ( s , -TO_RESET ) == OK ) break ;
  1130.   }
  1131.   return err ;
  1132. } 
  1133.  
  1134.  
  1135. /* Terminate session.  Makes sure modem is responding, sends modem reset
  1136.    commands, resets fax device to original state, removes lock files. */
  1137.  
  1138. int end_session ( )
  1139. {
  1140.   int i, err ;
  1141.   err = faxsync ( "Q0V1" ) ;
  1142.  
  1143.   for ( i=0 ; ! err && i<nzopt ; i++ )
  1144.     if ( cmd( zopt[i] , -TO_RESET ) != OK  && ! igniniterr )
  1145.       err = msg ("E3modem reset command (%s) failed", zopt[i]) ;
  1146.  
  1147.   if ( ! err ) err = ttymode ( ORIGINAL ) ;
  1148.   unlockall ( ) ;
  1149.   return err ;
  1150. } 
  1151.     
  1152.  
  1153. /* signal handler: hang up and exit */
  1154.  
  1155. void onsig ( int sig ) 
  1156. { 
  1157.   msg ( "Eterminating on signal %d", sig ) ; 
  1158.   end_session ( ) ;
  1159.   msg ("Idone, returning 5") ;
  1160.   exit(5) ; 
  1161. } 
  1162.  
  1163.  
  1164. /* Initialize session.  Try locking and opening fax device until opened or
  1165.    get error. Then set tty modes, register signal handler, setup
  1166.    modem. Returns 0 if OK, 2 on errors, 3 if initialization failed, 4 if no
  1167.    modem response. */
  1168.  
  1169. int begin_session ( char *faxfile )
  1170. {
  1171.   int i , err=0 , busy=0 , flags;
  1172.  
  1173.   do {
  1174.     err = lockall ( ) ;
  1175.     
  1176.     if ( ! err ) {
  1177.       faxdev = open ( faxfile , O_RDWR | O_NDELAY ) ;
  1178.       if ( faxdev < 0 )
  1179.     if ( errno == EBUSY ) err = 1 ; 
  1180.     else err = msg ( "ES2fax device open\n%s:", faxfile ) ;
  1181.       if ( ! err )
  1182.     if ( ( flags = fcntl( faxdev, F_GETFL, 0 ) ) < 0 ||
  1183.         fcntl( faxdev, F_SETFL, ( flags & ~O_NDELAY ) ) < 0 )
  1184.       err = msg ( "ES2fax device fcntl\n%s:", faxfile ) ;
  1185.     }
  1186.     
  1187.     if ( err == 1 ) { 
  1188.       if ( busy++ < 1 ) 
  1189.     msg ( "Wfax device %s locked or busy. waiting...", faxfile ) ;
  1190.       sleep ( LOCKPOLLDELAY ) ;
  1191.     }
  1192.  
  1193.   } while ( err == 1 ) ;
  1194.   
  1195.   if ( ! err ) msg ( "Iopened %s on fd %d", faxfile, faxdev ) ;
  1196.  
  1197.   if ( ! err ) err = ttymode ( COMMAND ) ;
  1198.   
  1199.   for ( i=0 ; ! err && catch [ i ] ; i++ ) 
  1200.     if ( signal ( catch [ i ] , onsig ) == SIG_ERR ) 
  1201.       err = msg ( "ES2can't set signal %d handler:", catch [ i ] ) ;
  1202.   
  1203.   if ( !err ) err = faxsync("Q0V1") ;
  1204.  
  1205.   for ( i=0 ; ! err && i<niopt ; i++ )
  1206.     if ( cmd( iopt[i] , -TO_RESET ) != OK && ! igniniterr )
  1207.       err = msg ("E3modem initialization command (%s) failed", iopt[i]) ;
  1208.  
  1209.   return err ;
  1210. }
  1211.  
  1212.  
  1213. /* Position `file' to start of page p (1...nfiles).  Assumes global
  1214.    variables 'fnames' and 'nfiles,' have been initialized.  This function
  1215.    looks ahead to see if there are more pages and if they are of a
  1216.    different format.  Eventually will handle multi-page files with embedded
  1217.    format information (e.g. TIFF-F).  Sets ppm to MPS if more pages to be
  1218.    sent with same format, EOM if more pages with different format, EOP if
  1219.    no more pages. Returns 0 if OK, 2 on errors.  Currently sets ppm to MPS
  1220.    or EOP only.  */
  1221.  
  1222. int rdpage ( int p , int *ppm )
  1223. {
  1224.   int err=0 ;
  1225.  
  1226.   if ( file && fclose ( file ) ) msg ("ES2file close:") ; 
  1227.  
  1228.   if ( p <= nfiles && p > 0 ) {
  1229.     if ( ( file = fopen ( fnames[p-1] , "rb" ) ) ) {
  1230.       msg ( "Iopened \"%s\" (p %d/%d)", fnames[p-1] , p, nfiles ) ;
  1231.       *ppm = p >= nfiles ? EOP : MPS ;
  1232.     } else {
  1233.       err = msg ("ES2 file open\n%s:", fnames[p-1]) ;
  1234.     }
  1235.   } else {
  1236.     err = msg ("E2 bad page number (%d)", p ) ;
  1237.   }
  1238.  
  1239.   return err ;
  1240. }
  1241.  
  1242. /* Same as rdpage() but creates new file name and opens `file' for
  1243.    writing. If page is -1 removes the most recently opened file. Assumes
  1244.    'fnampat' contains the strftime(3) pattern to be used for generating
  1245.    file names. Returns 0 if OK, 2 on errors. */
  1246.  
  1247. int wrpage ( int p )
  1248. {
  1249.   int err=0 ;
  1250.   static char fname [ FILENAME_MAX + 1 ] , base [ FILENAME_MAX + 1 ] ;
  1251.   time_t t ;
  1252.  
  1253.   t = time(0)  ;
  1254.   if ( ! *base ) strftime( base, FILENAME_MAX, fnamepat, localtime ( &t ) ) ;
  1255.  
  1256.   if ( file && fclose ( file ) ) msg ("ES2file close:") ; 
  1257.  
  1258.   if ( p == -1 ) {
  1259.     if ( remove ( fname ) )
  1260.       err = msg ( "ES2deleting file %s", fname ) ; 
  1261.     else
  1262.       msg ( "Iremoved %s", fname ) ; 
  1263.   } else {
  1264.     if ( *fname ) msg ( "Ireceived -> %s", fname ) ;
  1265.     sprintf ( fname, "%.*s.%03d", FILENAME_MAX - 5, base, p ) ;
  1266.     if( ( file = fopen ( fname , "rb" ) ) )
  1267.       err = msg ( "E2file (%s) already exists." ) ; 
  1268.     else
  1269.       if ( ( file = fopen ( fname , "wb" ) ) == 0 )
  1270.     err = msg ("ES2opening file\n%s:", fname) ; 
  1271.  
  1272.     if ( ! err ) msg ( "Iopened file %s", fname ) ;
  1273.   }
  1274.   return err ;
  1275. }
  1276.  
  1277.  
  1278. /* Send data for one page. Enable serial port flow control.  Read
  1279.    characters from file and pad lines if necessary.  Bit-reverse characters
  1280.    and escape DLE before storing in buffer.  Flush buffer if enough
  1281.    characters stored.  Append RTC if needed.  Send DLE-ETX and return
  1282.    serial port to command mode when done. Returns 0 if OK, non-0 on
  1283.    errors. */
  1284.  
  1285. int send_data( )
  1286. {
  1287.   int done=0, err=0;
  1288.   int lastc=0, c ;
  1289.   int eol=0, len=0, llen=0, eolcnt=0, rtc=0, skip=0 ;
  1290.   int bytes=0, pad=0, linec=0, lines=0 ;
  1291.   int i, noise=0 ;
  1292.   time_t start, dt ;
  1293.   dtree *t4p = t4tree ;
  1294.  
  1295.   done = err = ttymode ( SEND ) ; 
  1296.   start = time(0) ;
  1297.  
  1298.   while ( ! done ) {
  1299.  
  1300.     if ( ( c = getc ( file ) ) != EOF ) {
  1301.  
  1302. #define T4CODE(l) ( l < 0 ? (eol=l,llen=len,len=0) : (len+=l) ) 
  1303.       T4CTST(c) ;
  1304. #undef T4CODE
  1305.  
  1306.       if ( eol ) {
  1307.     if ( ! llen ) {
  1308.       if ( ++eolcnt >= 6 ) done = rtc = 1 ; 
  1309.     } else {
  1310.       eolcnt=0 ;
  1311.     }
  1312.     if ( eol == -2 ) 
  1313.       msg ("W- image error (line %d)", lines ) ;
  1314.     if ( ! skip ) {
  1315.       lines++ ; 
  1316.       while ( ( linec < minlen || lastc ) ) { 
  1317.         faxputc ( lastc = 0 ) ; 
  1318.         linec++ ; 
  1319.         pad++ ; 
  1320.       }
  1321.       linec = 0 ;
  1322.     }
  1323.     if ( decimate ) {
  1324.       if ( skip ) {
  1325.         skip = 0 ;
  1326.       } else {
  1327.         faxputc ( lastc = 0 ) ; /* force enough zeroes for next EOL */
  1328.         pad++ ; 
  1329.         skip = 1 ;
  1330.       }
  1331.     }
  1332.     if ( faxobytes() > MINWRITE ) { 
  1333.       if ( faxflush() ) done=err=2 ;  
  1334.     }
  1335.     eol=0 ;
  1336.       }
  1337.       if ( ! skip || ! llen ) {
  1338.     faxputc ( lastc = txbitorder [ c ] ) ; 
  1339.     linec ++ ;
  1340.     bytes++ ;
  1341.     if ( lastc == DLE ) { faxputc ( lastc = DLE ) ; linec++ ; pad++ ; }
  1342.       }    
  1343.     } else {
  1344.       done = 1 ;
  1345.       if ( ferror ( file ) ) err = msg ("ES2file read:") ;
  1346.     }
  1347.   }
  1348.  
  1349.   if ( ! err && ! rtc ) {
  1350.     for ( i=0 ; i<T4RTCLEN ; i++ ) faxputdatac ( (T4RTC)[i] ) ;
  1351.     msg ( "I- added RTC (%d bytes)" , T4RTCLEN ) ;
  1352.     pad += T4RTCLEN ;
  1353.   } 
  1354.  
  1355.   for ( ; ( c = faxgetc ( 0 ) ) != EOF ; noise++ ) 
  1356.     msg ( "W-+%s" , cname ( c ) ) ; 
  1357.   if ( noise ) msg ("W- : %d byte(s) received while sending", noise ) ;
  1358.     
  1359.   faxputs ( DLE_ETX ) ;        /* and faxflush() */
  1360.  
  1361.   ckcmd ( &err, 0, TO_DRAIN, OK, 0 ) ;
  1362.  
  1363.   dt = time(0) - start ;
  1364.   msg ("Isent %d lines  %d+%d bytes  %d s  %d bps" , 
  1365.        lines, bytes, pad, (int) dt, ((bytes+pad)*8)/dt ) ;
  1366.  
  1367.   if ( ! err ) err = ttymode ( COMMAND ) ; 
  1368.  
  1369.   return err ;
  1370. }
  1371.  
  1372.  
  1373. /* Receive data. Get characters from the modem and check for
  1374.    errors/EOF.  Remove long runs of zeroes (T.4 FILL). If in DLE
  1375.    escape check for DLE, end of data or protocol violation.
  1376.    Otherwise, test for DLE & write the character out.  Check that
  1377.    the output file is still OK.  If not, send one CANcel
  1378.    character and wait for protocol to complete.  */
  1379.  
  1380. int receive_data ( )
  1381. {
  1382.   int done=0, err=0, nulls=0, c ;
  1383.   int bytes=0, lines=0, nerr=0 ;
  1384.   int eol=0, eolcnt=0, len=0, llen=0, lastlen=0, rtc=0 ;
  1385.   dtree *t4p = t4tree ;
  1386.  
  1387.   while ( ! done ) {
  1388.  
  1389.     if ( ( c = faxgetc( TO_CHAR ) ) == DLE ) {
  1390.       if ( ( c = faxgetc( TO_CHAR ) ) == ETX ) done = 1 ;
  1391.       else if ( c != DLE ) {
  1392.     msg ( "W- \"%s\" received after DLE", cname ( c ) ) ;
  1393.     continue ;
  1394.       }
  1395.     }    
  1396.     if ( c == EOF ) {
  1397.       done = err = msg ("E3fax device read timeout") ;
  1398.       continue ;
  1399.     } 
  1400.     if ( c == 0 ) {
  1401.       if ( ++nulls > MAXNULLS ) {
  1402.     continue ;
  1403.       }
  1404.     } else {
  1405.       nulls = 0 ;
  1406.     }
  1407.     if ( ! done && ! rtc ) {
  1408.       putc ( c = rxbitorder [ c ] , file ) ;
  1409.       bytes++ ;
  1410.     }
  1411. #define T4CODE(l) ( l<0 ? (eol=l, llen=len, len=0) : (len+=l) ) 
  1412.       T4CTST(c) ;
  1413. #undef T4CODE
  1414.     if ( eol ) {
  1415.       lines++ ;
  1416.       if ( ( ( llen != lastlen ) && llen && lastlen && lines > 3 ) ) {
  1417.     nerr++ ;
  1418.     msg ("R-+ (%d:%d)", lines, llen ) ;
  1419.       }
  1420.       lastlen = llen ;
  1421.       if ( ! llen ) {
  1422.     if ( ++eolcnt >= 6 ) rtc = 1 ; 
  1423.       } else {
  1424.     eolcnt=0 ;
  1425.       }
  1426.       eol=0 ; 
  1427.     }
  1428.  
  1429.     if ( ! err && ferror ( file ) ) {
  1430.       err = msg ("ES2fax file write:") ;
  1431.       faxputcnow ( CAN ) ;
  1432.       msg ("Wreceive CANcelled") ;
  1433.     } 
  1434.  
  1435.   } /* while */
  1436.   
  1437.   if ( nerr ) msg ("R-  : reception errors" ) ;
  1438.   nerr /= 2 ;
  1439.   if ( nerr ) msg ("W- %d reception errors", nerr ) ;
  1440.  
  1441.   ckcmd ( &err, 0, TO_C2EOR, ( c1 ? NO : OK ) , 0 ) ;
  1442.   
  1443.   if ( ! err && ! rtc ) {
  1444.     fwrite ( T4RTC , sizeof ( u_char ) , T4RTCLEN , file ) ;
  1445.     msg ( "I- added RTC (%d bytes)" , T4RTCLEN ) ;
  1446.   }
  1447.  
  1448.   msg ( "I- received %d lines, %d bytes, %d errors", lines, bytes, nerr ) ;
  1449.  
  1450.   good = nerr < maxpgerr ;
  1451.   return err ;
  1452. }
  1453.  
  1454.  
  1455. /* Send training check sequence of n zeroes.  Returns 0 or 2 on error. */
  1456.  
  1457. int puttrain ( const char *s , int n )
  1458. {
  1459.   int i, err=0 ;
  1460.  
  1461.   ckcmd ( &err, s , TO_FT , CONNECT, 0 ) ;
  1462.  
  1463.   if ( ! err ) {
  1464.  
  1465.     ttymode ( SEND ) ;
  1466.     for ( i=0 ; ! err && i < n ; i++ ) {
  1467.       faxputc ( 0 ) ;
  1468.       if ( ! ( i & 63 ) ) faxflush ( ) ;
  1469.     }
  1470.     faxputc ( 1 ) ;        /* disable zero-fill padding */
  1471.     faxputs ( DLE_ETX ) ;
  1472.     ttymode ( COMMAND ) ;
  1473.  
  1474.     msg ( "I- sent TCF (%d bytes)", n ) ;
  1475.  
  1476.     ckcmd ( &err, 0, TO_DRAIN, OK, 0 ) ;
  1477.   }
  1478.  
  1479.   return err ;
  1480. }
  1481.  
  1482. /* Checks n bytes of received training check sequence. Skips first n/16
  1483.    bytes.  Returns 0 if OK or ignoring training errors, 1 if too many
  1484.    errors/not enough data, or 3 on other errors. */
  1485.  
  1486. int gettrain ( const char *s , int n ) 
  1487. { 
  1488.   int err=0, c, i, errcnt=0, skip=n/16 ;
  1489.  
  1490.   ckcmd ( &err, s , TO_FT , CONNECT, 0 ) ;
  1491.   
  1492.   for ( i=0 ; ! err && ( c = faxgetdatac ( TO_CHAR ) ) >= 0 ; i++ )
  1493.     if ( c != 0 && i >= skip && i < n+skip ) errcnt++ ;
  1494.   
  1495.   ckcmd ( &err, 0, TO_RTCMD, NO, 0 ) ;
  1496.   
  1497.   if ( !err )
  1498.     msg ( "I- received TCF (%s: %d error(s) in %d/%d bytes)", 
  1499.      ( err = i<n || errcnt>MAXTRAINERR ) ? "failed" : "passed" , 
  1500.      errcnt, n, i ) ;
  1501.  
  1502.   return err ;
  1503. }
  1504.  
  1505. /* Log sent/received HDLC frame.  Display of these messages is delayed to
  1506.    avoid possible timing problems. */
  1507.  
  1508. void logfr ( const char *s , const char *nm , u_char *p , int n )
  1509. {
  1510.   int i=0 ;
  1511.   msg ( "I- %s %s", s, nm ) ;
  1512.   msg ( n > 10 ? "H- %s %d bytes:" : "H-+ %s %d bytes:" , s, n ) ;
  1513.   for ( i=0 ; i<n ; i++ ) {
  1514.     msg ( "H-+  %02x" , p[i] & 0xff ) ;
  1515.     if ( ( i&0xf ) == 0xf && i != n-1 ) msg ( "H-" ) ;
  1516.   }
  1517.   msg ( "H-") ;
  1518. }
  1519.  
  1520. /* Send HDLC control frame of type type.  Extra bits are OR'ed to the frame
  1521.    type (FCF) if this frame follows a previous one (no +FTH required) or if
  1522.    more frames will follow.  Sets up flag, address, and fax control field
  1523.    (FCF) bytes in `buf'.  Sends these plus `len` additional bytes.
  1524.    Terminates with DLE-ETX and checks response.  Returns 0 if OK, 2 or 3 on
  1525.    error. */
  1526.  
  1527. #define MORE_FR  0x100 
  1528. #define SUB_FR 0x200 
  1529.  
  1530. int putframe ( int type, u_char *buf , int len )
  1531. {
  1532.   int err=0, i ;
  1533.  
  1534.   buf [ 0 ] = 0xff ;
  1535.   buf [ 1 ] = type & MORE_FR ? 0xc0 : 0xc8 ;
  1536.   buf [ 2 ] = type & 0xff ;
  1537.  
  1538.   if ( ! ( type & SUB_FR ) )
  1539.     ckcmd ( &err, "+FTH=3" , TO_FT, CONNECT, 0 ) ;
  1540.  
  1541.   if ( ! err ) {
  1542.     ttymode ( SEND ) ;
  1543.     for ( i=0 ; ! err && i< len+3 ; i++ )  faxputdatac ( buf [ i ] ) ;
  1544.     faxputs ( DLE_ETX ) ;
  1545.     ttymode ( COMMAND ) ;
  1546.  
  1547.     ckcmd ( &err, 0, TO_DRAIN, type & MORE_FR ? CONNECT : OK , 0 ) ;
  1548.     if ( ! err ) 
  1549.       logfr ( "sent", frname(type & 0x7f), buf, len+3 ) ;
  1550.   }
  1551.  
  1552.   return err ;
  1553. }
  1554.  
  1555.  
  1556. /* Read HDLC frame and store it in buffer buf of size n.  Skips
  1557.    issuing +FRH command on pass==0.  Returns length of frame if
  1558.    OK, EOF on timeout, -3 if any errors as per T.30 5.4.2 (too
  1559.    long, FCS error) */
  1560.  
  1561. int getframe ( int pass , u_char *buf , int n , int t )
  1562. {
  1563.   int err=0, c, i=0 ;
  1564.  
  1565.   if ( pass && ( c = cmd ( "+FRH=3" , t ) ) != CONNECT ) 
  1566.     err = ( c == EOF ) ? -EOF : msg ( "E3get frame command failed") ;
  1567.   
  1568.   if ( err == -EOF ) { faxputc ( CAN ) ; cmd ( "" , TO_ABRT ) ; }
  1569.  
  1570.   if ( ! err ) {
  1571.     for ( i=0 ; ( c = faxgetdatac ( pass ? TO_CHAR : t ) ) >= 0  ; i++ )
  1572.       if ( i < n ) buf[ i ] = c ;
  1573.     if ( c == EOF ) 
  1574.       err = i ? msg ( "E3timed out reading frame data") : EOF ;
  1575.     if ( i >= n ) err = msg ( "E3frame too long (%d bytes)", i ) ;
  1576.   } 
  1577.  
  1578.   ckcmd ( &err, 0, TO_RTCMD, OK, CONNECT ) ;
  1579.  
  1580.   return err ? -err : ( i < n ? i : n ) ;
  1581. }
  1582.  
  1583.  
  1584. /* Reverse bit and byte order of ID strings as per T.30 5.3.6.2.4-6 */
  1585.  
  1586. void revcpy ( u_char *from , u_char *to )
  1587. {
  1588.   int i, j ;
  1589.   for ( i=0, j=IDLEN-1 ; i<IDLEN ; i++, j-- ) 
  1590.     to [ i ] = normalbits [ from [ j ] & 0xff ] ;
  1591. }
  1592.  
  1593.  
  1594. /* Handle procedure interrupt requests (just print message for now).
  1595.    Returns 0. */
  1596.  
  1597. int pr_int( )
  1598. {
  1599.   return msg ("W0procedure interrupt request ignored" ) ;
  1600. }
  1601.  
  1602.  
  1603. /* Class 1 send.  Each received frame elicits an appropriate reply.
  1604.    Optional or unrecognized frames are ignored.  Terminates by sending DCN
  1605.    after receiving MCF after EOP or on error.  Timeouts, bad frames or CRP
  1606.    repeat last command up to MAXRETRY times.  On training check failures
  1607.    the speed (remote capability br) is reduced. The lowest speed is retried
  1608.    MAXTRAIN times.  Page transmission failures are retried NTXRETRY
  1609.    times. */
  1610.  
  1611.  
  1612. enum replies
  1613. { NONE=0x100, DCS1, DCS2, TXDATA, PPM, DONE, BADFR, TIMEOUT, SENDDIS } ;
  1614.  
  1615. int c1send ( int started ) 
  1616. { 
  1617.   int err=0, done=0, pass=started, page=1, frame=NONE, reply=DONE ;
  1618.   int frlen, rxdislen=0, disbit=0 ;
  1619.   int cmdtry=0, pagetry=0, traintry=0 ;
  1620.   int ppm=EOP ;
  1621.   u_char buf [ MAXFRLEN ] , *fif=buf+3 ;
  1622.  
  1623.   for ( pass=started ; ! done ; pass++ ) {
  1624.  
  1625.     if ( err ) {
  1626.       frame = NONE ;
  1627.     } else {
  1628.       frlen = getframe ( pass, buf, MAXFRLEN, started ? T3S : T1 ) ;
  1629.       if ( frlen < 3 ) {
  1630.     frame = CRP ;
  1631.       } else {
  1632.     frame = buf [ 2 ] & 0x7f ;
  1633.     logfr ( "received" , frname(frame), buf , frlen ) ;
  1634.     cmdtry = 0 ;
  1635.       }
  1636.     }
  1637.  
  1638.     switch ( frame ) {
  1639.       
  1640.     case CRP:
  1641.       if ( !started || cmdtry++ >= MAXRETRY ) 
  1642.     err = msg ( "E3 no response from remote" ) ;
  1643.       break ;
  1644.  
  1645.     case NSF:
  1646.       reply = NONE ;
  1647.       break ;
  1648.  
  1649.     case CSI:
  1650.       revcpy ( fif , (u_char*) remoteid ) ;
  1651.       msg ( "I- remote ID=\"%*.*s\"" , IDLEN, IDLEN, remoteid ) ;
  1652.       reply = NONE ;
  1653.       break ;
  1654.  
  1655.     case DIS:
  1656.       started = 1 ;
  1657.       disbit = 0x80 ;
  1658.       rxdislen = dislen ( fif ) ;
  1659.       mkcap ( fif , remote , 1 ) ;
  1660.       reply = DCS1 ;
  1661.       break ;
  1662.  
  1663.     case CFR:
  1664.       reply = TXDATA ;
  1665.       break ;
  1666.  
  1667.     case FTT:
  1668.       if ( (remote[BR] = fallback[session[BR]]) > 0 || traintry++ < MAXTRAIN ) 
  1669.     reply = DCS2 ; 
  1670.       else
  1671.     err = msg ( "E1failed to train") ; 
  1672.       break ;
  1673.  
  1674.     case PIP: 
  1675.       pr_int ( ) ; 
  1676.     case RTP:
  1677.     case MCF:
  1678.       page++ ;
  1679.       pagetry=0 ;
  1680.       if ( ppm == MPS && frame == MCF ) reply = TXDATA ;
  1681.       else if ( ppm == EOP ) done = 1 ;
  1682.       else reply = DCS2 ; 
  1683.       break ;
  1684.  
  1685.     case PIN: 
  1686.       pr_int ( ) ;
  1687.     case RTN:
  1688.       if ( pagetry++ < NTXRETRY ) reply = DCS2 ;
  1689.       else err = msg( "E1too many page send retries" ) ;
  1690.       break ;
  1691.  
  1692.     case DCN:
  1693.       err = msg ( "E3remote disconnected") ;
  1694.       break ;
  1695.  
  1696.     case NONE:
  1697.       break ;
  1698.  
  1699.     default:
  1700.       break ;
  1701.  
  1702.     } /* switch ( frame ) */
  1703.  
  1704.     switch ( err || done ? DONE : reply ) {
  1705.  
  1706.     case  DCS1:
  1707.       revcpy ( (u_char*) localid , fif ) ;
  1708.       err = putframe ( TSI + MORE_FR + disbit , buf, IDLEN ) ;      
  1709.                                /* fall through */
  1710.     case DCS2:
  1711.       mincap ( local, remote, session ) ;
  1712.       mkdis ( session , fif , rxdislen , 0 ) ;
  1713.       if ( !err ) err = 
  1714.     putframe ( DCS + (reply==DCS1 ? SUB_FR : 0) + disbit, buf, rxdislen ) ;
  1715.       ckcmd ( &err, "+FTS=8", TO_FT, OK, 0 ) ;
  1716.       if ( !err ) err = 
  1717.     puttrain ( c1cmd [1][1][session[BR]] , 1.65 * cps [ session[BR] ] ) ;
  1718.       reply = DCS2 ;
  1719.       break ;
  1720.  
  1721.     case TXDATA:
  1722.       if ( !err ) err = rdpage ( page, &ppm ) ;
  1723.       ckcmd ( &err,  c1cmd [1][0][session[BR]] , TO_FT, CONNECT, 0 ) ;
  1724.       if ( !err ) err = send_data ( ) ;
  1725.       ckcmd ( &err, "+FTS=8", TO_FT, OK, 0 ) ;      
  1726.                                /* fall through */
  1727.     case  PPM:
  1728.       if ( !err ) err =    putframe ( ppm + disbit, buf, 0 ) ;
  1729.       reply = PPM ;
  1730.       break ;
  1731.  
  1732.     case DONE:
  1733.       putframe ( DCN + disbit, buf, 0 ) ; 
  1734.       done = 1 ;
  1735.       break ;
  1736.  
  1737.     case NONE:
  1738.       break ;
  1739.  
  1740.     default:
  1741.       err = msg ( "E3can't happen(reply)" ) ;
  1742.       break ;
  1743.  
  1744.     } /* switch ( reply ) */
  1745.  
  1746.   } /* for ( ! done ) */
  1747.  
  1748.   return err ;
  1749. }
  1750.  
  1751.  
  1752. /* Class 1 receive.  Sends DIS until gets a DCS or times out.  Sends ppr
  1753.   after ppm and receives data after DCS or MPS. Note: TCF (training check
  1754.   data) is received 75 +/- 20 ms after DCS so there should be no lengthy
  1755.   processing between DCS and gettrain(). */
  1756.  
  1757. int c1receive ( int started ) 
  1758. { 
  1759.   int err=0, done=0, page=1, pass, frame, frlen ;
  1760.   u_char buf[MAXFRLEN], *fif=buf+3 ;
  1761.  
  1762.   err = wrpage ( page ) ;
  1763.  
  1764.   for ( pass=started ; ! err && ! done ; pass++ ) {
  1765.  
  1766.     if ( pass > 0 ) {
  1767.       frlen = getframe(pass, buf, MAXFRLEN, started ? T2 : T4 ) ;
  1768.       if ( frlen == EOF ) {
  1769.     frame = started ? TIMEOUT : ( pass < MAXDIS ? SENDDIS : TIMEOUT ) ;
  1770.       } else if ( frlen < 3 ) {
  1771.     frame = started ? NONE : ( pass < MAXDIS ? SENDDIS : NONE ) ;
  1772.       } else {
  1773.     frame = buf [ 2 ] & 0x7f ;
  1774.     logfr ( "received" , frname(frame), buf , frlen ) ;
  1775.       }
  1776.     } else {
  1777.       frame=SENDDIS ;
  1778.     }
  1779.  
  1780.     switch ( frame ) {
  1781.       
  1782.     case SENDDIS:
  1783.       revcpy ( (u_char*) localid, fif ) ;
  1784.       if ( !err ) err = 
  1785.     putframe ( CSI + MORE_FR + ( pass ? 0 : SUB_FR ), buf, IDLEN ) ;
  1786.       mkdis ( local , fif , DEFDISLEN , 1 ) ;
  1787.       if ( !err ) err = 
  1788.     putframe ( DIS + SUB_FR , buf, DEFDISLEN ) ;
  1789.       break ;
  1790.       
  1791.     case TIMEOUT:
  1792.       done = err = msg ( "E3timed out waiting for sender" ) ;
  1793.       break; 
  1794.  
  1795.     case BADFR :
  1796.       msg ( "W bad frame" ) ;
  1797.       break ;
  1798.  
  1799.     case TSI: ;
  1800.       revcpy ( fif , (u_char*) remoteid ) ;
  1801.       msg ( "I- remote ID=\"%*.*s\"" , IDLEN, IDLEN, remoteid ) ;
  1802.       break ;
  1803.       
  1804.     case DCS: ;
  1805.       started = 1 ;
  1806.       mkcap ( fif , session  , 0 ) ;
  1807.       printcap ( "session" , session ) ;
  1808.       if ( gettrain ( c1cmd [0][1][session[BR]], cps[session[BR]] ) == 0 ) {
  1809.     if ( !err ) err = putframe ( CFR, buf, 0 ) ;
  1810.     if ( !err ) goto getdata ;
  1811.       } else {
  1812.     if ( !err ) err = putframe ( FTT, buf, 0 ) ;
  1813.       }
  1814.       break ;
  1815.  
  1816.     case PRI_EOM:
  1817.     case PRI_MPS:
  1818.     case PRI_EOP:
  1819.       pr_int() ;
  1820.  
  1821.     case EOM:
  1822.     case MPS:
  1823.     case EOP:
  1824.       err = wrpage ( ++page ) ;    
  1825.       if ( ! err )
  1826.     if ( good ) err = putframe ( MCF, buf, 0 ) ;
  1827.     else        err = putframe ( RTN, buf, 0 ) ;
  1828.       if ( ! err && good && ( frame == MPS || frame == PRI_MPS ) )
  1829.     goto getdata ; 
  1830.       if ( ! err && good && ( frame == EOM || frame == PRI_EOM ) ) {
  1831.     pass=0 ;
  1832.     ckcmd ( &err, "+FTS=8", TO_FT, OK, 0 ) ;      
  1833.       }
  1834.       break ;
  1835.  
  1836.     getdata:
  1837.       ckcmd ( &err, c1cmd [0][0][session[BR]] , TO_FT, CONNECT, 0 ) ;
  1838.       if ( !err ) err = receive_data (  ) ;
  1839.       break ;
  1840.       
  1841.     case DCN:
  1842.       done = 1 ;
  1843.       break;
  1844.  
  1845.     } /* switch */
  1846.     
  1847.   } /* do */
  1848.  
  1849.   wrpage ( -1 ) ;        /* remove last file */
  1850.   return err ;
  1851. }
  1852.  
  1853. /* Class 2 fax transmission.  Retries each page up to NTXRETRY times.
  1854.    Transmission begins after DC2 or XON is received.  Sends the data and
  1855.    sends appropriate post-page message.  Checks for 'good' status set in
  1856.    cmd() by +FPTS: responses. */
  1857.  
  1858. int c2send ( )
  1859. {
  1860.   int c, page, err=0, done=0, try, ppm=0, noise=0 ;
  1861.  
  1862.   for ( page=1 ; !err && ! done ; page++ ) {
  1863.  
  1864.     for ( try=good=0 ; !err && !good && try<NTXRETRY ; try++ ) {
  1865.  
  1866.       err = rdpage ( page , &ppm ) ;
  1867.  
  1868.       ckcmd ( &err, "+FDT" , TO_C2B , CONNECT, 0 ) ;
  1869.   
  1870.       if ( ! err ) 
  1871.     while ( !err && ( c = faxgetc ( TO_C2X ) ) != XON && c != DC2 )
  1872.       if ( c == EOF ) {
  1873.         msg ( "Wno XON/DC2 received after CONNECT") ;
  1874.         break ;
  1875.       } else { 
  1876.         msg ( "W+%s", cname ( c ) ) ; 
  1877.         noise++ ; 
  1878.       }
  1879.  
  1880.       if ( noise ) {
  1881.     msg ( "Wreceived (%d) characters while waiting to send", noise ) ;
  1882.     noise = 0 ;
  1883.       }
  1884.  
  1885.       if ( ! err ) err = send_data ( ) ;
  1886.  
  1887.       good = 1 ; /* assume good if no +FPTS: */
  1888.       ckcmd ( &err, ppm == EOP ? "+FET=2" : "+FET=0" , TO_C2PP, OK, 0 ) ;
  1889.  
  1890.       if ( hsc > 0 ) err = msg ( "E2abnormal termination (code %d)", hsc ) ;
  1891.     }
  1892.     if ( ppm == EOP ) done = 1 ;
  1893.     if ( try >= NTXRETRY ) {
  1894.       err = msg ( "E2too many page send retries" ) ;
  1895.       cmd ( "+FK", T3S ) ;
  1896.     }
  1897.   } 
  1898.   return err ; 
  1899. }
  1900.  
  1901. /* Class 2 fax reception.  Send fax data receive command.  If
  1902.    response is OK, then no more pages are coming.  If it's
  1903.    CONNECT receive the data for one page.  Returns 0 or >= 2 for
  1904.    errors.  */
  1905.  
  1906. int c2receive ( )
  1907. {
  1908.   int err=0, page=1, done=0, c ;
  1909.  
  1910.   err = wrpage ( page ) ;
  1911.  
  1912.   while ( ! err && ! done && hsc < 0 ) {
  1913.     if ( ( c = cmd ( "+FDR" , TO_C2R ) ) == CONNECT ) {
  1914.       faxputcnow ( startchar ) ;
  1915.       err = receive_data ( ) ;
  1916.       ckcmd ( &err, good ? "+FPTS=1" : "+FPTS=2", T3S , OK, 0 ) ;
  1917.       if ( ! err ) err = wrpage ( ++page ) ;
  1918.     } else {
  1919.       if ( c == OK ) { wrpage ( -1 ) ; done = 1 ; } 
  1920.       else err = msg ( "E3receive (+FDR) command failed") ;
  1921.     }
  1922.   } 
  1923.   if ( hsc > 0 ) err = msg ( "E2abnormal call termination (code %d)", hsc ) ;
  1924.   
  1925.   return err ;
  1926. }
  1927.  
  1928. /* Dial a number and send a fax. */
  1929.  
  1930. int send ( char *tel , char *faxfile )
  1931. {
  1932.   char c, s [ 128 ] ;
  1933.   int err=0 ;
  1934.  
  1935.   msg ( "Idialing %.127s", tel ) ;
  1936.   sprintf ( s , "D%.127s" , tel ) ;
  1937.  
  1938.   err = begin_session ( faxfile ) ;
  1939.  
  1940.   if ( ! err ) {
  1941.     if ( ( ( c = cmd ( s , TO_A ) ) == ( c1 ? CONNECT : OK ) ) && hsc < 0 ) 
  1942.       msg ( "Iconnected" ) ; 
  1943.     else if ( c ==  BUSY ) 
  1944.       err = msg ( "W1number is busy" ) ; 
  1945.     else 
  1946.       err = msg ( "E2can't establish session" ) ;
  1947.  
  1948.     if ( ! err ) 
  1949.       err = c1 ? c1send ( 0 ) : c2send ( ) ;
  1950.  
  1951.     if ( err != 1 && err < 4 ) end_session( ) ;
  1952.   }
  1953.  
  1954.   return err ;
  1955. }
  1956.  
  1957.  
  1958. /* Receive a fax.  Open modem device and initialize it.  Remove locks if
  1959.    sharing device with outgoing calls.  If waiting for call, wait for modem
  1960.    activity, else answer phone.  Figure out what mode we answered in and
  1961.    handle call appropriately.  Re-lock if necessary. Then exec *getty or
  1962.    run class 1 or class 2 reception routines. Modems prompt as follows
  1963.    after answering: Class 0: CONNECT nnn for data; Class 1: FAX + CONNECT
  1964.    for fax, DATA + CONNECT nnn for data, just CONNECT for fax if +FAE=0;
  1965.    Class 2: CONNECT (data) or OK (fax). ("+FCON" and "CONNECT FAX" are 
  1966.    status messages, not prompts). */
  1967.  
  1968. int receive ( char *faxfile )
  1969. {
  1970.   enum connectmode { NONE, DATAMODE, FAXMODE } ; 
  1971.   enum connectmode mode=NONE ;
  1972.   int c=0, err ;
  1973.  
  1974.   if ( ( err = begin_session ( faxfile ) ) == 0 ) {
  1975.  
  1976.     if ( ! err && share ) err = unlockall ( ) ;
  1977.  
  1978.     if ( ! err && waitforcall ) {
  1979.       msg ( "Iwaiting for activity on %s", faxfile ) ;
  1980.       faxdata ( -1 ) ;
  1981.       msg ( "Iactivity detected at ") ;
  1982.     }
  1983.   
  1984.     if ( ! err && share ) {
  1985.       msleep ( 200 ) ;        /* let other programs lock port  */
  1986.       err = lockall ( ) ;
  1987.     }
  1988.  
  1989.     if ( ! err && softadans && *getty ) {
  1990.       if ( cmd ( ( waitforcall ? 0 : "A" ) , TO_DATAF ) == CONNECT ) 
  1991.     mode = DATAMODE ;
  1992.       else {
  1993.     int i ; /* abort data answer mode & set fax mode to try again */
  1994.     for ( i=0 ; i<3 ; i++ ) 
  1995.       if ( cmd ( c1 ? "+FCLASS=1" : "+FCLASS=2" , -TO_RESET ) == OK )
  1996.         break ; 
  1997.       }
  1998.     }
  1999.     if ( ! err && mode == NONE ) {
  2000.       c = cmd ( ! waitforcall || ( softadans && *getty ) ? "A" : 0 , TO_A ) ;
  2001.       if ( c1 )
  2002.     mode = ( c == CONNECT ) ? ( datamode ? DATAMODE : FAXMODE ) : NONE ;
  2003.       else
  2004.     mode = ( c == CONNECT ) ? DATAMODE : ( c == OK ? FAXMODE : NONE ) ;
  2005.     }
  2006.     
  2007.     if ( err || hsc >= 0 ) mode = NONE ;
  2008.  
  2009.     if ( ! err )
  2010.       switch ( mode ) {
  2011.       case DATAMODE : {
  2012.         char buf [ MAXGETTY ] ;
  2013.     msg ( "Idata call answered") ;
  2014.     sprintf ( buf , getty , crate, crate, crate, crate, crate, crate ) ;
  2015.     msg ( "Iexec'ing /bin/sh -c \"%s\"" , buf ) ;
  2016.     execl ( "/bin/sh" , "sh" , "-c" , buf , (void*) 0 ) ; 
  2017.     err = msg ( "ES2exec failed:" ) ;
  2018.     break ; }
  2019.       case FAXMODE :
  2020.     msg ( "Ifax call answered") ;
  2021.     break ;
  2022.       case NONE:
  2023.     err = msg ( "E3unable to answer call") ;
  2024.     break ;
  2025.       }
  2026.     
  2027.     if ( ! err ) err = c1 ? c1receive ( 0 ) : c2receive ( ) ;
  2028.     
  2029.     if ( err != 1 && err < 4 ) end_session( ) ;   /* if not locked */
  2030.   }
  2031.   
  2032.   return err  ;
  2033. }
  2034.  
  2035.  
  2036. /* Simple (one option per argument) version of getopt(3). */
  2037.  
  2038. int optind = 1 ;
  2039. char *optarg ;
  2040.  
  2041. int nextopt( int argc, char **argv, char *args )
  2042. {
  2043.   char *a, *p ;
  2044.  
  2045.   if ( optind >= argc || *(a = argv[optind]) != '-' ) return -1 ;
  2046.   optind++ ;
  2047.  
  2048.   if ( ! *(a+1) || ! ( p = strchr ( args , *(a+1) ) ) )
  2049.     return msg ( "Eunknown option (%s)" , a ) , '?' ; 
  2050.  
  2051.   if ( *(p+1) != ':' ) optarg = 0 ;
  2052.   else
  2053.     if ( *(a+2) ) optarg = a+2 ;
  2054.     else
  2055.       if ( optind >= argc ) return msg ( "Eno argument for (%s)", a ) , '?' ;
  2056.       else optarg = argv [ optind++ ] ;
  2057.   return *(a+1) ;
  2058. }
  2059.  
  2060.  
  2061. /* Fax send/receive program for Class 1 or 2 fax modems. Initialize
  2062.    character name, bit reversal and T.4 decoding tables and process
  2063.    arguments.  Returns 0 on success, 1 if number busy or device locked, 2
  2064.    for errors, 3 for protocol errors, 4 if no modem response, 5 on fatal
  2065.    signal. */
  2066.  
  2067. int main( int argc, char **argv)
  2068. {
  2069.   int i, err=0 , c, nlocks=0 ;
  2070.   char *faxfile = FAXFILE ;
  2071.   char capinit [ CMDBUFSIZE ] , idinit [ CMDBUFSIZE ] ;
  2072.   char msgbuf [ MAXMSGBUF ] ;
  2073.  
  2074.   argv0 = argv[0] ;
  2075.  
  2076.   setvbuf ( LOGF , msgbuf , _IOFBF , MAXMSGBUF ) ;
  2077.  
  2078.   msg ( "I " Version "  starts ") ;
  2079.   msg ( "I " Copyright "  (compiled "__DATE__ " " __TIME__ ")" ) ;
  2080.  
  2081.   argv0 = strrchr ( argv0 , '/' )  ;
  2082.   if ( ! argv0 ) argv0 = argv[0] ; else argv0++ ;
  2083.  
  2084.   cname ( 0 ) ;
  2085.   for ( i=0 ; i<256 ; i++ ) normalbits [ reversebits [ i ] = i ] = 
  2086.     ( i& 1 ? 128:0 ) | ( i& 2 ? 64:0 ) | ( i& 4 ? 32:0 ) | ( i&  8 ? 16:0 ) |
  2087.     ( i&16 ?   8:0 ) | ( i&32 ?  4:0 ) | ( i&64 ?  2:0 ) | ( i&128 ?  1:0 ) ;
  2088.   t4tree = unpktree( ) ;
  2089.   
  2090.   while (!err && (c=nextopt(argc,argv,"c:d:g:i:l:o:q:r:st:v:wx:z:T") ) != -1) {
  2091.     switch (c) {
  2092.     case 'c': 
  2093.       err = str2cap ( optarg , local ) ;
  2094.       sprintf ( capinit , "+FDCC=%.*s" , CMDBUFSIZE-7, optarg ) ;
  2095.       if ( !err && !c1 ) { optarg = capinit ; goto addopt ; }
  2096.       break ;
  2097.     case 'l': 
  2098.       if ( strlen ( optarg ) > IDLEN ) 
  2099.     msg("Wlocal ID (%s) truncated to 20 characters", optarg ) ;
  2100.       if ( strspn ( optarg, " +0123456789" ) != strlen ( optarg ) )
  2101.     msg("Wlocal ID (%s) has non-standard characters", optarg ) ;
  2102.       sprintf ( localid, "%*.*s", IDLEN, IDLEN, optarg ) ;
  2103.       sprintf ( idinit , "+FLID=\"%.*s\"" , CMDBUFSIZE-9, localid ) ;
  2104.       if ( !c1 ) { optarg = idinit ; goto addopt ; }
  2105.       break ;
  2106.     case 'i': 
  2107.     addopt:
  2108.       if ( niopt < MAXIOPT ) iopt [ niopt++ ] = optarg ;
  2109.       else err = msg ( "E2too many modem init commands"); 
  2110.       break ;
  2111.     case 'z': 
  2112.       if ( nzopt < MAXIOPT ) zopt [ nzopt++ ] = optarg ;
  2113.       else err = msg ( "E2too many modem reset commands"); 
  2114.       break ;
  2115.     case 'd': faxfile = optarg ; break ;
  2116.     case 'g': getty = optarg ; break ;
  2117.     case 'o': 
  2118.       for ( ; *optarg ; optarg++ ) 
  2119.     switch ( *optarg ) {
  2120.     case '1' : c1 = 1 ; break ;
  2121.     case 'a' : softadans = 1 ;  break ;
  2122.     case 'e' : igniniterr = igniniterr ? 0 : 1 ;  break ;
  2123.     case 'r' : rxbitorder = reversebits ; break ;
  2124.     case 'x' : startchar = XON ; break ;
  2125.     case 'z' : cmdpause += T_CMD ; break ;
  2126.      default : msg ( "Wunrecognized protocol option (%c)", *optarg ) ; 
  2127.     }
  2128.       break ;
  2129.     case 'q':
  2130.       if ( sscanf ( optarg , "%d", &maxpgerr ) != 1 )
  2131.     err=msg ("E2can't read quality (-q) argument (%s)", optarg ) ;
  2132.       break;
  2133.     case 'r': 
  2134.       fnamepat = optarg ;
  2135.       err = receive ( faxfile ) ; 
  2136.       break;
  2137.     case 's': share = 1 ; break;
  2138.     case 't': 
  2139.       fnames = argv + optind ;
  2140.       nfiles = argc - optind ;
  2141.       err = send ( optarg , faxfile ) ; 
  2142.       break;
  2143.     case 'v': 
  2144.       verb = optarg ;
  2145.       if ( strchr ( verb , 'a' ) )
  2146.       for ( i=0 ; i<argc ; i++ ) msg ( "Iargv[%d]=%s", i, argv[i]) ; 
  2147.       break ;
  2148.     case 'w': waitforcall = 1 ; break ;
  2149.     case 'x': 
  2150.       if ( nlocks < MAXLKFILE ) lkfiles [ nlocks++ ] = optarg ; 
  2151.       else err = msg ( "E2too many lock files" ) ; 
  2152.       break ;
  2153.     case 'T':            /* test: begin+end session */
  2154.       if ( ( err = begin_session ( faxfile ) ) == 0 ) end_session( ) ;
  2155.       break ;
  2156.     default : fprintf ( stderr, Usage, argv0 ) ; err = 2 ; break ;
  2157.     }
  2158.   }
  2159.  
  2160.   msg ( "Idone, returning %d", err ) ;
  2161.   return err ;
  2162. }
  2163.